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: