original_docstring: Take input data source and generates TF Example splits.
  
      Args:
        input_dict: Input dict from input key to a list of Artifacts. Depends on
          detailed example gen implementation.
        output_dict: Output dict from output key to a list of Artifacts.
          - examples: splits of tf examples.
        exec_properties: A dict of execution properties. Depends on detailed
          example gen implementation.
          - input: JSON string of example_gen_pb2.Input instance, providing input
            configuration.
          - output: JSON string of example_gen_pb2.Output instance, providing
            output configuration.
  
      Returns:
        None
      
docstring: Take input data source and generates TF Example splits.
docstring_tokens: Take input data source and generates TF Example splits .
code: def Do(self, input_dict: Dict[Text, List[types.TfxArtifact]],
           output_dict: Dict[Text, List[types.TfxArtifact]],
           exec_properties: Dict[Text, Any]) -> None:
      """Take input data source and generates TF Example splits.
  
      Args:
        input_dict: Input dict from input key to a list of Artifacts. Depends on
          detailed example gen implementation.
        output_dict: Output dict from output key to a list of Artifacts.
          - examples: splits of tf examples.
        exec_properties: A dict of execution properties. Depends on detailed
          example gen implementation.
          - input: JSON string of example_gen_pb2.Input instance, providing input
            configuration.
          - output: JSON string of example_gen_pb2.Output instance, providing
            output configuration.
  
      Returns:
        None
      """
      self._log_startup(input_dict, output_dict, exec_properties)
  
      tf.logging.info('Generating examples.')
      with beam.Pipeline(argv=self._get_beam_pipeline_args()) as pipeline:
        example_splits = self.GenerateExamplesByBeam(pipeline, input_dict,
                                                     exec_properties)
  
        # pylint: disable=expression-not-assigned, no-value-for-parameter
        for split_name, example_split in example_splits.items():
          (example_split
           | 'WriteSplit' + split_name >> _WriteSplit(
               types.get_split_uri(output_dict['examples'], split_name)))
        # pylint: enable=expression-not-assigned, no-value-for-parameter
  
      tf.logging.info('Examples generated.')
code_tokens: def Do ( self , input_dict : Dict [ Text , List [ types . TfxArtifact ] ] , output_dict : Dict [ Text , List [ types . TfxArtifact ] ] , exec_properties : Dict [ Text , Any ] ) -> None : self . _log_startup ( input_dict , output_dict , exec_properties ) tf . logging . info ( 'Generating examples.' ) with beam . Pipeline ( argv = self . _get_beam_pipeline_args ( ) ) as pipeline : example_splits = self . GenerateExamplesByBeam ( pipeline , input_dict , exec_properties ) for split_name , example_split in example_splits . items ( ) : ( example_split | 'WriteSplit' + split_name >> _WriteSplit ( types . get_split_uri ( output_dict [ 'examples' ] , split_name ) ) ) tf . logging . info ( 'Examples generated.' )
short_docstring: Take input data source and generates TF Example splits.
short_docstring_tokens: Take input data source and generates TF Example splits .
comment: """Take input data source and generates TF Example splits.
  
      Args:
        input_dict: Input dict from input key to a list of Artifacts. Depends on
          detailed example gen implementation.
        output_dict: Output dict from output key to a list of Artifacts.
          - examples: splits of tf examples.
        exec_properties: A dict of execution properties. Depends on detailed
          example gen implementation.
          - input: JSON string of example_gen_pb2.Input instance, providing input
            configuration.
          - output: JSON string of example_gen_pb2.Output instance, providing
            output configuration.
  
      Returns:
        None
      """$SEP$# pylint: disable=expression-not-assigned, no-value-for-parameter$SEP$# pylint: enable=expression-not-assigned, no-value-for-parameter