public class TestJobService
extends org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
A TestJobService
always returns a fixed staging endpoint, job preparation id, job id,
and job state. As soon as a job is run, it is put into the given job state.
Constructor and Description |
---|
TestJobService(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor stagingEndpoint,
java.lang.String preparationId,
java.lang.String jobId,
org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum jobState,
org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults metrics) |
Modifier and Type | Method and Description |
---|---|
void |
getJobMetrics(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsRequest request,
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsResponse> responseObserver) |
void |
getState(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateRequest request,
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.JobStateEvent> responseObserver) |
void |
prepare(org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobRequest request,
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobResponse> responseObserver) |
void |
run(org.apache.beam.model.jobmanagement.v1.JobApi.RunJobRequest request,
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.RunJobResponse> responseObserver) |
public TestJobService(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor stagingEndpoint, java.lang.String preparationId, java.lang.String jobId, org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum jobState, org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults metrics)
public void prepare(org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.PrepareJobResponse> responseObserver)
prepare
in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
public void run(org.apache.beam.model.jobmanagement.v1.JobApi.RunJobRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.RunJobResponse> responseObserver)
run
in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
public void getState(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobStateRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.JobStateEvent> responseObserver)
getState
in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
public void getJobMetrics(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsResponse> responseObserver)
getJobMetrics
in class org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase