parameters: (self,
                 base_path,
                 mapreduce_spec,
                 shard_id,
                 slice_id,
                 input_reader,
                 initial_input_reader,
                 output_writer=None,
                 retries=0,
                 handler=None)
docstring: Init.
  
      Args:
        base_path: base path of this mapreduce job. Deprecated.
        mapreduce_spec: an instance of MapReduceSpec.
        shard_id: shard id.
        slice_id: slice id. When enqueuing task for the next slice, this number
          is incremented by 1.
        input_reader: input reader instance for this shard.
        initial_input_reader: the input reader instance before any iteration.
          Used by shard retry.
        output_writer: output writer instance for this shard, if exists.
        retries: the number of retries of the current shard. Used to drop
          tasks from old retries.
        handler: map/reduce handler.
docstring_summary: Init.
docstring_tokens: Init .
function: def __init__(self,
                 base_path,
                 mapreduce_spec,
                 shard_id,
                 slice_id,
                 input_reader,
                 initial_input_reader,
                 output_writer=None,
                 retries=0,
                 handler=None):
      """Init.
  
      Args:
        base_path: base path of this mapreduce job. Deprecated.
        mapreduce_spec: an instance of MapReduceSpec.
        shard_id: shard id.
        slice_id: slice id. When enqueuing task for the next slice, this number
          is incremented by 1.
        input_reader: input reader instance for this shard.
        initial_input_reader: the input reader instance before any iteration.
          Used by shard retry.
        output_writer: output writer instance for this shard, if exists.
        retries: the number of retries of the current shard. Used to drop
          tasks from old retries.
        handler: map/reduce handler.
      """
      self.base_path = base_path
      self.mapreduce_spec = mapreduce_spec
      self.shard_id = shard_id
      self.slice_id = slice_id
      self.input_reader = input_reader
      self.initial_input_reader = initial_input_reader
      self.output_writer = output_writer
      self.retries = retries
      self.handler = handler
      self._input_reader_json = self.input_reader.to_json()
function_tokens: def __init__ ( self , base_path , mapreduce_spec , shard_id , slice_id , input_reader , initial_input_reader , output_writer = None , retries = 0 , handler = None ) : self . base_path = base_path self . mapreduce_spec = mapreduce_spec self . shard_id = shard_id self . slice_id = slice_id self . input_reader = input_reader self . initial_input_reader = initial_input_reader self . output_writer = output_writer self . retries = retries self . handler = handler self . _input_reader_json = self . input_reader . to_json ( )