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, java.lang.String retrievalToken, org.apache.beam.vendor.protobuf.v3.com.google.protobuf.Struct pipelineOptions)
abstract java.lang.String	jobId()
abstract java.lang.String	jobName()
abstract org.apache.beam.vendor.protobuf.v3.com.google.protobuf.Struct	pipelineOptions()
abstract java.lang.String	retrievalToken()
org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo	toProvisionInfo()

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,
                             java.lang.String retrievalToken,
                             org.apache.beam.vendor.protobuf.v3.com.google.protobuf.Struct pipelineOptions)

jobId

public abstract java.lang.String jobId()

jobName

public abstract java.lang.String jobName()

retrievalToken

public abstract java.lang.String retrievalToken()

pipelineOptions

public abstract org.apache.beam.vendor.protobuf.v3.com.google.protobuf.Struct pipelineOptions()

toProvisionInfo

public org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo toProvisionInfo()