apache_beam.portability.api.beam_fn_api_pb2_grpc module

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnControlStub(channel)

Bases: future.types.newobject.newobject

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.beam_fn_api_pb2_grpc.BeamFnControlServicer

Bases: future.types.newobject.newobject

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

Control(request_iterator, context)

Instructions sent by the runner to the SDK requesting different types of work.

apache_beam.portability.api.beam_fn_api_pb2_grpc.add_BeamFnControlServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnDataStub(channel)

Bases: future.types.newobject.newobject

Stable

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnDataServicer

Bases: future.types.newobject.newobject

Stable

Data(request_iterator, context)

Used to send data between harnesses.

apache_beam.portability.api.beam_fn_api_pb2_grpc.add_BeamFnDataServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnStateStub(channel)

Bases: future.types.newobject.newobject

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnStateServicer

Bases: future.types.newobject.newobject

State(request_iterator, context)

Used to get/append/clear state stored by the runner on behalf of the SDK.

apache_beam.portability.api.beam_fn_api_pb2_grpc.add_BeamFnStateServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnLoggingStub(channel)

Bases: future.types.newobject.newobject

Stable

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnLoggingServicer

Bases: future.types.newobject.newobject

Stable

Logging(request_iterator, context)

Allows for the SDK to emit log entries which the runner can associate with the active job.

apache_beam.portability.api.beam_fn_api_pb2_grpc.add_BeamFnLoggingServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnExternalWorkerPoolStub(channel)

Bases: future.types.newobject.newobject

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnExternalWorkerPoolServicer

Bases: future.types.newobject.newobject

StartWorker(request, context)

Start the SDK worker with the given ID.

StopWorker(request, context)

Stop the SDK worker.

apache_beam.portability.api.beam_fn_api_pb2_grpc.add_BeamFnExternalWorkerPoolServicer_to_server(servicer, server)