apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc module¶
Client and server classes corresponding to protobuf-defined services.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnControlStub
(channel)[source]¶ Bases:
object
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do. Stable
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnControlServicer
[source]¶ Bases:
object
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do. Stable
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnControlServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnControl
[source]¶ Bases:
object
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do. Stable
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnDataStub
(channel)[source]¶ Bases:
object
Stable
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnDataServicer
[source]¶ Bases:
object
Stable
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnDataServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnData
[source]¶ Bases:
object
Stable
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnStateStub
(channel)[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnStateServicer
[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnStateServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnState
[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnLoggingStub
(channel)[source]¶ Bases:
object
Stable
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnLoggingServicer
[source]¶ Bases:
object
Stable
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnLoggingServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnLogging
[source]¶ Bases:
object
Stable
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnExternalWorkerPoolStub
(channel)[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnExternalWorkerPoolServicer
[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnExternalWorkerPoolServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnExternalWorkerPool
[source]¶ Bases:
object
Missing associated documentation comment in .proto file.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnWorkerStatusStub
(channel)[source]¶ Bases:
object
API for SDKs to report debug-related statuses to runner during pipeline execution.
Constructor.
Parameters: channel – A grpc.Channel.
-
class
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
BeamFnWorkerStatusServicer
[source]¶ Bases:
object
API for SDKs to report debug-related statuses to runner during pipeline execution.
-
apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc.
add_BeamFnWorkerStatusServicer_to_server
(servicer, server)[source]¶