org.apache.beam.runners.reference.job

Class ReferenceRunnerJobService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

org.apache.beam.runners.reference.job.ReferenceRunnerJobService

All Implemented Interfaces:

io.grpc.BindableService, java.lang.AutoCloseable, FnService

public class ReferenceRunnerJobService
extends org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
implements FnService

The ReferenceRunner uses the portability framework to execute a Pipeline on a single machine.

Method Summary

Modifier and Type	Method and Description
void	cancel(org.apache.beam.model.jobmanagement.v1.JobApi.CancelJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.CancelJobResponse> responseObserver)
void	close() .
static ReferenceRunnerJobService	create(ServerFactory serverFactory)
void	getState(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateRequest request, io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateResponse> responseObserver)
void	prepare(org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobResponse> responseObserver)
void	run(org.apache.beam.model.jobmanagement.v1.JobApi.RunJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.RunJobResponse> responseObserver)
ReferenceRunnerJobService	withStagingPathSupplier(java.util.concurrent.Callable<java.nio.file.Path> supplier)

Methods inherited from class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

bindService, getMessageStream, getStateStream

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.grpc.BindableService

bindService

Method Detail

create

public static ReferenceRunnerJobService create(ServerFactory serverFactory)

withStagingPathSupplier

public ReferenceRunnerJobService withStagingPathSupplier(java.util.concurrent.Callable<java.nio.file.Path> supplier)

prepare

public void prepare(org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobRequest request,
                    io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobResponse> responseObserver)

Overrides:

prepare in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

run

public void run(org.apache.beam.model.jobmanagement.v1.JobApi.RunJobRequest request,
                io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.RunJobResponse> responseObserver)

Overrides:

run in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

getState

public void getState(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateRequest request,
                     io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateResponse> responseObserver)

Overrides:

getState in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

cancel

public void cancel(org.apache.beam.model.jobmanagement.v1.JobApi.CancelJobRequest request,
                   io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.CancelJobResponse> responseObserver)

Overrides:

cancel in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase

close

public void close()
           throws java.lang.Exception

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

Throws:

java.lang.Exception