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: