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.vendor.grpc.v1p26p0.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()

Method Summary

Modifier and Type	Method and Description
void	close()
void	expand(org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionRequest request, org.apache.beam.vendor.grpc.v1p26p0.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()

Method Detail

expand

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

Overrides:

expand in class org.apache.beam.model.expansion.v1.ExpansionServiceGrpc.ExpansionServiceImplBase

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