Package org.apache.beam.runners.portability.testing

Class TestJobService

java.lang.Object
org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
org.apache.beam.runners.portability.testing.TestJobService
All Implemented Interfaces:
org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.AsyncService, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService
public class TestJobService extends org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.JobServiceImplBase
A JobService for tests.

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 Summary

    Constructors
    Constructor
    Description
    TestJobService(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor stagingEndpoint, String preparationId, String jobId, org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum jobState, org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults metrics)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    getJobMetrics(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsRequest request, org.apache.beam.vendor.grpc.v1p69p0.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.v1p69p0.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.v1p69p0.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.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.RunJobResponse> responseObserver)
     

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

    bindService

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.beam.model.jobmanagement.v1.JobServiceGrpc.AsyncService

    cancel, describePipelineOptions, drain, getJobs, getMessageStream, getPipeline, getStateStream

  • Constructor Details

    • TestJobService

      public TestJobService(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor stagingEndpoint, String preparationId, String jobId, org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum jobState, org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults metrics)

  • Method Details

    • prepare

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

    • run

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

    • getState

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

    • getJobMetrics

      public void getJobMetrics(org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsRequest request, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.JobApi.GetJobMetricsResponse> responseObserver)