code: def _test_do(self, payload_format):
      exec_properties = {
          standard_component_specs.INPUT_BASE_KEY: self._input_data_dir,
          standard_component_specs.INPUT_CONFIG_KEY: self._input_config,
          standard_component_specs.OUTPUT_CONFIG_KEY: self._output_config,
          standard_component_specs.OUTPUT_DATA_FORMAT_KEY: payload_format,
      }
  
      output_data_dir = os.path.join(
          os.environ.get(
              "TEST_UNDECLARED_OUTPUTS_DIR", self.get_temp_dir()
          ),
          self._testMethodName,
      )
  
      # Create output dict.
      self.examples = standard_artifacts.Examples()
      self.examples.uri = output_data_dir
      output_dict = {
          standard_component_specs.EXAMPLES_KEY: [self.examples]
      }
  
      # Run executor.
      import_example_gen = executor.Executor()
      import_example_gen.Do({}, output_dict, exec_properties)
  
      self.assertEqual(
          artifact_utils.encode_split_names(["train", "eval"]),
          self.examples.split_names,
      )
  
      # Check import_example_gen outputs.
      if payload_format == example_gen_pb2.PayloadFormat.FORMAT_PARQUET:
          train_output_file = os.path.join(
              self.examples.uri,
              "Split-train",
              "data_parquet-00000-of-00001.parquet",
          )
          eval_output_file = os.path.join(
              self.examples.uri,
              "Split-eval",
              "data_parquet-00000-of-00001.parquet",
          )
      else:
          train_output_file = os.path.join(
              self.examples.uri,
              "Split-train",
              "data_tfrecord-00000-of-00001.gz",
          )
          eval_output_file = os.path.join(
              self.examples.uri,
              "Split-eval",
              "data_tfrecord-00000-of-00001.gz",
          )
  
      self.assertTrue(fileio.exists(train_output_file))
      self.assertTrue(fileio.exists(eval_output_file))
      self.assertGreater(
          fileio.open(train_output_file).size(),
          fileio.open(eval_output_file).size(),
      )
  
imports: import os
  import apache_beam
  from apache_beam.testing import util
  import tensorflow
  from tfx.components.example_gen import utils
  from tfx.components.example_gen.import_example_gen import executor
  from tfx.dsl.io import fileio
  from tfx.proto import example_gen_pb2
  from tfx.types import artifact_utils
  from tfx.types import standard_artifacts
  from tfx.types import standard_component_specs
  from tfx.utils import proto_utils
label_desc: Use image node_id 3 for calling the ExecutorTest obj's underlying member method code with example usage: obj._test_do(payload_format) without return types