(self, shard_ended_input)
This is called whenever the record processor has reached the end of the shard. The record processor needs to
        checkpoint to notify the KCL that it's ok to start processing the child shard(s).  Failing to checkpoint will
        trigger a retry of the shard end

        :param amazon_kclpy.messages.ShardEndedInput shard_ended_input: information about reaching the end of the shard.
This is called whenever the record processor has reached the end of the shard. The record processor needs to
        checkpoint to notify the KCL that it's ok to start processing the child shard(s).  Failing to checkpoint will
        trigger a retry of the shard end
This is called whenever the record processor has reached the end of the shard . The record processor needs to checkpoint to notify the KCL that it s ok to start processing the child shard ( s ) . Failing to checkpoint will trigger a retry of the shard end
def shard_ended(self, shard_ended_input):
        """
        This is called whenever the record processor has reached the end of the shard. The record processor needs to
        checkpoint to notify the KCL that it's ok to start processing the child shard(s).  Failing to checkpoint will
        trigger a retry of the shard end

        :param amazon_kclpy.messages.ShardEndedInput shard_ended_input: information about reaching the end of the shard.
        """
        raise NotImplementedError
def shard_ended ( self , shard_ended_input ) : raise NotImplementedError