Package org.apache.beam.runners.fnexecution.provisioning

Class JobInfo

java.lang.Object

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

All Implemented Interfaces:

Serializable

public abstract class JobInfo
extends Object
implements 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	Description
JobInfo()

Method Summary

Modifier and Type	Method	Description
static JobInfo	create(String jobId, String jobName, String retrievalToken, org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.Struct pipelineOptions)
abstract String	jobId()
abstract String	jobName()
abstract org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.Struct	pipelineOptions()
abstract 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 Details

JobInfo

public JobInfo()

Method Details

create

public static JobInfo create(String jobId,
 String jobName,
 String retrievalToken,
 org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.Struct pipelineOptions)

jobId

public abstract String jobId()

jobName

public abstract String jobName()

retrievalToken

public abstract String retrievalToken()

pipelineOptions

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

toProvisionInfo

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