(self, process_records_input)
This is called whenever records are received.  The method will be provided the batch of records that were
        received.  A checkpointer is also supplied that allows the application to checkpoint its progress within the
        shard.

        :param amazon_kclpy.messages.ProcessRecordsInput process_records_input: the records, metadata about the
            records, and a checkpointer.
This is called whenever records are received.  The method will be provided the batch of records that were
        received.  A checkpointer is also supplied that allows the application to checkpoint its progress within the
        shard.
This is called whenever records are received . The method will be provided the batch of records that were received . A checkpointer is also supplied that allows the application to checkpoint its progress within the shard .
def process_records(self, process_records_input):
        """
        This is called whenever records are received.  The method will be provided the batch of records that were
        received.  A checkpointer is also supplied that allows the application to checkpoint its progress within the
        shard.

        :param amazon_kclpy.messages.ProcessRecordsInput process_records_input: the records, metadata about the
            records, and a checkpointer.

        """
        raise NotImplementedError
def process_records ( self , process_records_input ) : raise NotImplementedError