class_docstr: BeamExecutorOperator handles Beam based executor's init and execution.
  
  Attributes:
    extra_flags: Extra flags that will pass to Beam executors. It come from
      two sources in the order:
      1. The `extra_flags` set in the executor spec.
      2. The flags passed in when starting the program by users or by other
         systems. The interpretation of these flags relying on the executor
         implementation.
    beam_pipeline_args: Beam specific arguments that will pass to Beam
      executors. It comes from `beam_pipeline_args` set in the Beam executor
      spec.
class_docstr_tok: ["BeamExecutorOperator","handles","Beam","based","executor","'s","init","and","execution",".","Attributes",":","extra_flags",":","Extra","flags","that","will","pass","to","Beam","executors",".","It","come","from","two","sources","in","the","order",":","1",".","The","`","extra_flags","`","set","in","the","executor","spec",".","2",".","The","flags","passed","in","when","starting","the","program","by","users","or","by","other","systems",".","The","interpretation","of","these","flags","relying","on","the","executor","implementation",".","beam_pipeline_args",":","Beam","specific","arguments","that","will","pass","to","Beam","executors",".","It","comes","from","`","beam_pipeline_args","`","set","in","the","Beam","executor","spec","."]
docstr: Initializes a BeamExecutorOperator.
  
  Args:
    executor_spec: The specification of how to initialize the executor.
    platform_config: The specification of how to allocate resource for the
      executor.
docstr_tok: ["Initializes","a","BeamExecutorOperator",".","Args",":","executor_spec",":","The","specification","of","how","to","initialize","the","executor",".","platform_config",":","The","specification","of","how","to","allocate","resource","for","the","executor","."]
code: def __init__(
      self,
      executor_spec: message.Message,
      platform_config: Optional[message.Message] = None,
  ):
      """Initializes a BeamExecutorOperator.
  
      Args:
        executor_spec: The specification of how to initialize the executor.
        platform_config: The specification of how to allocate resource for the
          executor.
      """
      del platform_config
      super().__init__(executor_spec)
      beam_executor_spec = cast(
          executable_spec_pb2.BeamExecutableSpec, self._executor_spec
      )
      self._executor_cls = import_utils.import_class_by_path(
          beam_executor_spec.python_executor_spec.class_path
      )
      self.extra_flags = []
      self.extra_flags.extend(
          beam_executor_spec.python_executor_spec.extra_flags
      )
      self.beam_pipeline_args = []
  
      self.beam_pipeline_args.extend(
          beam_executor_spec.beam_pipeline_args_placeholders
      )
  
file_path: tfx/tfx/orchestration/portable/beam_executor_operator.py
imports: from typing import Any, Callable, Optional, cast
  from tfx.dsl.compiler import placeholder_utils
  from tfx.dsl.components.base import base_beam_executor
  from tfx.orchestration.portable import base_executor_operator
  from tfx.orchestration.portable import data_types
  from tfx.orchestration.portable import python_executor_operator
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import execution_result_pb2
  from tfx.utils import import_utils
  from google.protobuf import message
label_desc: Use image node_id 1 to create a new BeamExecutorOperator object from inherited base classes: base_executor_operator with example: obj = BeamExecutorOperator(executor_spec, platform_config)