org.apache.beam.sdk.transformservice

Class ExpansionService

java.lang.Object

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

org.apache.beam.sdk.transformservice.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

Method Summary

Modifier and Type	Method and Description
void	close()
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)

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

Method Detail

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