apache_beam.portability.api.beam_runner_api_pb2_grpc module

class apache_beam.portability.api.beam_runner_api_pb2_grpc.TestStreamServiceStub(channel)[source]

Bases: object

Constructor.

Parameters:channel – A grpc.Channel.
class apache_beam.portability.api.beam_runner_api_pb2_grpc.TestStreamServiceServicer[source]

Bases: object

Events(request, context)[source]

A TestStream will request for events using this RPC.

apache_beam.portability.api.beam_runner_api_pb2_grpc.add_TestStreamServiceServicer_to_server(servicer, server)[source]