apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc.ExpansionServiceStub(channel)

Bases: object

Job Service for constructing pipelines

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc.ExpansionServiceServicer

Bases: object

Job Service for constructing pipelines

Expand(request, context)

Missing associated documentation comment in .proto file.

DiscoverSchemaTransform(request, context)

A RPC to discover already registered SchemaTransformProviders. See https://s.apache.org/easy-multi-language for more details.

apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc.add_ExpansionServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc.ExpansionService

Bases: object

Job Service for constructing pipelines

static Expand(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static DiscoverSchemaTransform(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)