|View source on GitHub|
Abstract TFX executor class for Beam powered components.
tfx.dsl.components.base.base_beam_executor.BaseBeamExecutor( context: Optional[
tfx.dsl.components.base.base_executor.BaseExecutor.Context] = None )
Do( input_dict: Dict[Text, List[types.Artifact]], output_dict: Dict[Text, List[types.Artifact]], exec_properties: Dict[Text, Any] ) -> Optional[execution_result_pb2.ExecutorOutput]
Execute underlying component implementation.
||Input dict from input key to a list of Artifacts. These are often outputs of another component in the pipeline and passed to the component by the orchestration system.|
||Output dict from output key to a list of Artifacts. These are often consumed by a dependent component.|
||A dict of execution properties. These are inputs to pipeline with primitive types (int, string, float) and fully materialized when a pipeline is constructed. No dependency to other component or later injection from orchestration systems is necessary or possible on these values.|
|execution_result_pb2.ExecutorOutput or None.|