apache_beam.portability.api.org.apache.beam.model.fn_execution.v1 package

Submodules

• apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc module
  • BeamFnControlStub
  • BeamFnControlServicer
    • BeamFnControlServicer.Control()
    • BeamFnControlServicer.GetProcessBundleDescriptor()
  • add_BeamFnControlServicer_to_server()
  • BeamFnControl
    • BeamFnControl.Control()
    • BeamFnControl.GetProcessBundleDescriptor()
  • BeamFnDataStub
  • BeamFnDataServicer
    • BeamFnDataServicer.Data()
  • add_BeamFnDataServicer_to_server()
  • BeamFnData
    • BeamFnData.Data()
  • BeamFnStateStub
  • BeamFnStateServicer
    • BeamFnStateServicer.State()
  • add_BeamFnStateServicer_to_server()
  • BeamFnState
    • BeamFnState.State()
  • BeamFnLoggingStub
  • BeamFnLoggingServicer
    • BeamFnLoggingServicer.Logging()
  • add_BeamFnLoggingServicer_to_server()
  • BeamFnLogging
    • BeamFnLogging.Logging()
  • BeamFnExternalWorkerPoolStub
  • BeamFnExternalWorkerPoolServicer
    • BeamFnExternalWorkerPoolServicer.StartWorker()
    • BeamFnExternalWorkerPoolServicer.StopWorker()
  • add_BeamFnExternalWorkerPoolServicer_to_server()
  • BeamFnExternalWorkerPool
    • BeamFnExternalWorkerPool.StartWorker()
    • BeamFnExternalWorkerPool.StopWorker()
  • BeamFnWorkerStatusStub
  • BeamFnWorkerStatusServicer
    • BeamFnWorkerStatusServicer.WorkerStatus()
  • add_BeamFnWorkerStatusServicer_to_server()
  • BeamFnWorkerStatus
    • BeamFnWorkerStatus.WorkerStatus()
• apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_urns module
  • FnApiTransforms
    • FnApiTransforms.Runner
      • FnApiTransforms.Runner.DATA_SOURCE
      • FnApiTransforms.Runner.DATA_SINK
• apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc module
  • ProvisionServiceStub
  • ProvisionServiceServicer
    • ProvisionServiceServicer.GetProvisionInfo()
  • add_ProvisionServiceServicer_to_server()
  • ProvisionService
    • ProvisionService.GetProvisionInfo()