apache_beam.portability.api.org.apache.beam.model.interactive.v1.beam_interactive_api_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class apache_beam.portability.api.org.apache.beam.model.interactive.v1.beam_interactive_api_pb2_grpc.TestStreamServiceStub(channel)[source]

Bases: object

A gRPC service that serves cached TestStream events to a TestStream source. Used by Interactive Beam to replay recorded pipeline elements from a streaming cache.

Constructor.

Parameters:: channel – A grpc.Channel.

class apache_beam.portability.api.org.apache.beam.model.interactive.v1.beam_interactive_api_pb2_grpc.TestStreamServiceServicer[source]

Bases: object

A gRPC service that serves cached TestStream events to a TestStream source. Used by Interactive Beam to replay recorded pipeline elements from a streaming cache.

Events(request, context)[source]: A TestStream will request for events using this RPC.

apache_beam.portability.api.org.apache.beam.model.interactive.v1.beam_interactive_api_pb2_grpc.add_TestStreamServiceServicer_to_server(servicer, server)[source]

class apache_beam.portability.api.org.apache.beam.model.interactive.v1.beam_interactive_api_pb2_grpc.TestStreamService[source]

Bases: object

A gRPC service that serves cached TestStream events to a TestStream source. Used by Interactive Beam to replay recorded pipeline elements from a streaming cache.

static Events(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]