(self, checkpointer, record_processor)
Dispatches the shard ended message to the record processor

        :param checkpointer: the checkpointer to be used to officially end processing on the shard
        :param record_processor: the record processor that will handle the shard end message
Dispatches the shard ended message to the record processor
Dispatches the shard ended message to the record processor
def dispatch(self, checkpointer, record_processor):
        """
        Dispatches the shard ended message to the record processor

        :param checkpointer: the checkpointer to be used to officially end processing on the shard
        :param record_processor: the record processor that will handle the shard end message
        """
        self._checkpointer = checkpointer
        record_processor.shard_ended(self)
def dispatch ( self , checkpointer , record_processor ) : self . _checkpointer = checkpointer record_processor . shard_ended ( self )