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.v1p43p2.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(java.lang.String[] args)

Method Summary

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

Method Detail

createPipeline

protected Pipeline createPipeline()

expand

public void expand(org.apache.beam.model.expansion.v1.ExpansionApi.ExpansionRequest request,
                   org.apache.beam.vendor.grpc.v1p43p2.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