|View source on GitHub|
A specification of Beam executor.
tfx.dsl.components.base.executor_spec.BeamExecutorSpec( executor_class: Type[
||a subclass of base_executor.BaseExecutor used to execute this component (required).|
||extra flags to be set in the Python base executor.|
||arguments for Beam powered Components.|
Fully qualified class name for the executor class.
add_beam_pipeline_args( beam_pipeline_args: Iterable[str] ) -> None
add_extra_flags( extra_flags: Iterable[str] ) -> None
copy() -> "BeamExecutorSpec"
Makes a copy of the ExecutorSpec.
An abstract method to implement to make a copy of the ExecutorSpec instance. Deepcopy is preferred in the implementation. But if for any reason a deepcopy is not able to be made because of some fields are not deepcopyable, it is OK to make a shallow copy as long as the subfield is consider globally immutable.
|A copy of ExecutorSpec.|
encode( component_spec: Optional[
tfx.types.ComponentSpec] = None ) -> message.Message
Encodes ExecutorSpec into an IR proto for compiling.
This method will be used by DSL compiler to generate the corresponding IR.
||Optional. The ComponentSpec to help with the encoding.|
|An executor spec proto.|