Uses of Class
org.apache.flink.api.common.JobID

Packages that use JobID

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.functions
org.apache.flink.api.connector.sink2
org.apache.flink.core.execution
org.apache.flink.core.failure
org.apache.flink.util

Uses of JobID in org.apache.flink.api.common

Methods in org.apache.flink.api.common that return JobID

Modifier and Type	Method	Description
static JobID	JobID.fromByteArray(byte[] bytes)	Creates a new JobID from the given byte sequence.
static JobID	JobID.fromByteBuffer(ByteBuffer buf)
static JobID	JobID.fromHexString(String hexString)	Parses a JobID from the given string.
static JobID	JobID.generate()	Creates a new (statistically) random JobID.
JobID	JobInfo.getJobId()	Get the ID of the job.
JobID	JobInfoImpl.getJobId()
JobID	Plan.getJobId()	Gets the ID of the job that the dataflow plan belongs to.
JobID	JobSubmissionResult.getJobID()	Returns the JobID assigned to the job by the Flink runtime.

Methods in org.apache.flink.api.common with parameters of type JobID

Modifier and Type	Method	Description
void	Plan.setJobId(JobID jobId)	Sets the ID of the job that the dataflow plan belongs to.

Constructors in org.apache.flink.api.common with parameters of type JobID

Constructor	Description
JobExecutionResult(JobID jobID, long netRuntime, Map<String,OptionalFailure<Object>> accumulators)	Creates a new JobExecutionResult.
JobInfoImpl(JobID jobID, String jobName)
JobSubmissionResult(JobID jobID)

Uses of JobID in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return JobID

Modifier and Type	Method	Description
default JobID	RuntimeContext.getJobId()	Deprecated. This method is deprecated since Flink 1.19.

Uses of JobID in org.apache.flink.api.connector.sink2

Methods in org.apache.flink.api.connector.sink2 that return JobID

Modifier and Type	Method	Description
default JobID	InitContext.getJobId()	Deprecated. This method is deprecated since Flink 1.19.
JobID	Sink.InitContextWrapper.getJobId()	Deprecated.

Uses of JobID in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution that return JobID

Modifier and Type	Method	Description
JobID	DetachedJobExecutionResult.getJobID()
JobID	JobClient.getJobID()	Returns the JobID that uniquely identifies the job this client is scoped to.

Methods in org.apache.flink.core.execution with parameters of type JobID

Modifier and Type	Method	Description
void	JobStatusHook.onCanceled(JobID jobId)	When job get canceled by users.
void	JobStatusHook.onCreated(JobID jobId)	When Job becomes JobStatus.CREATED status, it would only be called one time.
void	JobStatusHook.onFailed(JobID jobId, Throwable throwable)	When job failed finally.
void	JobStatusHook.onFinished(JobID jobId)	When job finished successfully.

Constructors in org.apache.flink.core.execution with parameters of type JobID

Constructor	Description
DetachedJobExecutionResult(JobID jobID)

Uses of JobID in org.apache.flink.core.failure

Methods in org.apache.flink.core.failure that return JobID

Modifier and Type	Method	Description
default JobID	FailureEnricher.Context.getJobId()	Deprecated. This method is deprecated since Flink 1.19.

Uses of JobID in org.apache.flink.util

Methods in org.apache.flink.util with parameters of type JobID

Modifier and Type	Method	Description
static Map<String,String>	MdcUtils.asContextData(JobID jobID)
static Executor	MdcUtils.scopeToJob(JobID jobID, Executor executor)	Wrap the given Executor so that the given JobID is added before it executes any submitted commands and removed afterward.
static ExecutorService	MdcUtils.scopeToJob(JobID jobID, ExecutorService delegate)	Wrap the given ExecutorService so that the given JobID is added before it executes any submitted commands and removed afterward.
static ScheduledExecutorService	MdcUtils.scopeToJob(JobID jobID, ScheduledExecutorService ses)	Wrap the given ScheduledExecutorService so that the given JobID is added before it executes any submitted commands and removed afterward.