Module core.components.data_gen.executor

Functions

WriteToTFRecord(datapoints: Dict[str, Any], schema: Dict[str, Any], output_split_path: str) ‑> apache_beam.pvalue.PDone : Infers schema and writes to TFRecord

Classes

DataExecutor(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`
:   Args:
        input_dict:
        output_dict:
        exec_properties: