Module core.components.split_gen.executor

Functions

WriteSplit(example_split: apache_beam.pvalue.PCollection, output_split_path: str) ‑> apache_beam.pvalue.PDone : Shuffles and writes output split.

Classes

Executor(context: Union[tfx.dsl.components.base.base_executor.BaseExecutor.Context, NoneType] = None) : Abstract TFX executor class.

Constructs a beam based executor.

### Ancestors (in MRO)

* tfx.dsl.components.base.base_executor.BaseExecutor

### Methods

`Do(self, input_dict: Dict[str, List[tfx.types.artifact.Artifact]], output_dict: Dict[str, List[tfx.types.artifact.Artifact]], exec_properties: Dict[str, Any]) ‑> NoneType`
:   Write description regarding this beautiful executor.
    
    Args:
        input_dict:
        output_dict:
        exec_properties: