org.apache.beam.runners.jobsubmission

Class JobPreparation

java.lang.Object

org.apache.beam.runners.jobsubmission.JobPreparation

public abstract class JobPreparation
extends java.lang.Object

A job that has been prepared, but not invoked.

Constructor Summary

Constructors

Constructor and Description
JobPreparation()

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.runners.jobsubmission.JobPreparation.Builder	builder()
abstract java.lang.String	id()
abstract org.apache.beam.vendor.grpc.v1p26p0.com.google.protobuf.Struct	options()
abstract org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline	pipeline()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobPreparation

public JobPreparation()

Method Detail

builder

public static org.apache.beam.runners.jobsubmission.JobPreparation.Builder builder()

id

public abstract java.lang.String id()

pipeline

public abstract org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline()

options

public abstract org.apache.beam.vendor.grpc.v1p26p0.com.google.protobuf.Struct options()