org.apache.beam.runners.fnexecution.provisioning

Class JobInfo

java.lang.Object

org.apache.beam.runners.fnexecution.provisioning.JobInfo

All Implemented Interfaces:

java.io.Serializable

public abstract class JobInfo
extends java.lang.Object
implements java.io.Serializable

A subset of ProvisionApi.ProvisionInfo that specifies a unique job, while omitting fields that are not known to the runner operator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JobInfo()

Method Summary

Modifier and Type	Method and Description
static JobInfo	create(java.lang.String jobId, java.lang.String jobName, com.google.protobuf.Struct pipelineOptions)
abstract java.lang.String	jobId()
abstract java.lang.String	jobName()
abstract com.google.protobuf.Struct	pipelineOptions()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobInfo

public JobInfo()

Method Detail

create

public static JobInfo create(java.lang.String jobId,
                             java.lang.String jobName,
                             com.google.protobuf.Struct pipelineOptions)

jobId

public abstract java.lang.String jobId()

jobName

public abstract java.lang.String jobName()

pipelineOptions

public abstract com.google.protobuf.Struct pipelineOptions()