org.apache.beam.runners.reference.job

Class ReferenceRunnerJobService

java.lang.Object

org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

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

All Implemented Interfaces:

io.grpc.BindableService

public class ReferenceRunnerJobService
extends org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

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.sdk.common.runner.v1.JobApi.CancelJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.JobApi.CancelJobResponse> responseObserver)
static ReferenceRunnerJobService	create()
void	getState(org.apache.beam.sdk.common.runner.v1.JobApi.GetJobStateRequest request, io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.JobApi.GetJobStateResponse> responseObserver)
void	prepare(org.apache.beam.sdk.common.runner.v1.JobApi.PrepareJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.JobApi.PrepareJobResponse> responseObserver)
void	run(org.apache.beam.sdk.common.runner.v1.JobApi.RunJobRequest request, io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.JobApi.RunJobResponse> responseObserver)

Methods inherited from class org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

bindService, getMessageStream, getStateStream

Methods inherited from class java.lang.Object

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

Method Detail

create

public static ReferenceRunnerJobService create()

prepare

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

Overrides:

prepare in class org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

run

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

Overrides:

run in class org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

getState

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

Overrides:

getState in class org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase

cancel

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

Overrides:

cancel in class org.apache.beam.sdk.common.runner.v1.JobServiceGrpc.JobServiceImplBase