org.apache.beam.sdk.expansion.service

Class ExpansionService

java.lang.Object

org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.ExpansionServiceImplBase

org.apache.beam.sdk.expansion.service.ExpansionService

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.AsyncService, org.apache.beam.vendor.grpc.v1p54p0.io.grpc.BindableService

public class ExpansionService
extends org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.ExpansionServiceImplBase
implements java.lang.AutoCloseable

A service that allows pipeline expand transforms from a remote SDK.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ExpansionService.ExpansionServiceRegistrar A registrar that creates ExpansionService.TransformProvider instances from RunnerApi.FunctionSpecs.
static class	ExpansionService.ExternalTransformRegistrarLoader Exposes Java transforms via ExternalTransformRegistrar.
static interface	ExpansionService.TransformProvider<InputT extends PInput,OutputT extends POutput> Provides a mapping of RunnerApi.FunctionSpec to a PTransform, together with mappings of its inputs and outputs to maps of PCollections.

Constructor Summary

Constructors

Constructor and Description
ExpansionService()
ExpansionService(PipelineOptions opts)
ExpansionService(PipelineOptions opts, @Nullable java.lang.String loopbackAddress)
ExpansionService(java.lang.String[] args)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Pipeline	createPipeline(PipelineOptions requestOptions)
void	discoverSchemaTransform(org.apache.beam.model.expansion.v1.ExpansionApi.DiscoverSchemaTransformRequest request, org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.expansion.v1.ExpansionApi.DiscoverSchemaTransformResponse> responseObserver)
void	expand(org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionRequest request, org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionResponse> responseObserver)
static void	main(java.lang.String[] args)

Methods inherited from class org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.ExpansionServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExpansionService

public ExpansionService()

ExpansionService

public ExpansionService(java.lang.String[] args)

ExpansionService

public ExpansionService(PipelineOptions opts)

ExpansionService

public ExpansionService(PipelineOptions opts,
                        @Nullable java.lang.String loopbackAddress)

Method Detail

createPipeline

protected Pipeline createPipeline(PipelineOptions requestOptions)

expand

public void expand(org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionRequest request,
                   org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionResponse> responseObserver)

Specified by:

expand in interface org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.AsyncService

discoverSchemaTransform

public void discoverSchemaTransform(org.apache.beam.model.expansion.v1.ExpansionApi.DiscoverSchemaTransformRequest request,
                                    org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.expansion.v1.ExpansionApi.DiscoverSchemaTransformResponse> responseObserver)

Specified by:

discoverSchemaTransform in interface org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.AsyncService

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception