(self, initialize_input)
Called once by a KCLProcess before any calls to process_records

        :param amazon_kclpy.messages.InitializeInput initialize_input: Information about the lease that this record
            processor has been assigned.
Called once by a KCLProcess before any calls to process_records
Called once by a KCLProcess before any calls to process_records
def initialize(self, initialize_input):
        """
        Called once by a KCLProcess before any calls to process_records

        :param amazon_kclpy.messages.InitializeInput initialize_input: Information about the lease that this record
            processor has been assigned.
        """
        self._largest_seq = (None, None)
        self._last_checkpoint_time = time.time()
def initialize ( self , initialize_input ) : self . _largest_seq = ( None , None ) self . _last_checkpoint_time = time . time ( )