Interface InitContext
-
- All Known Subinterfaces:
CommitterInitContext,WriterInitContext
@Internal public interface InitContextCommon interface which exposes runtime info for creatingSinkWriterandCommitterobjects.
-
-
Field Summary
Fields Modifier and Type Field Description static longINITIAL_CHECKPOINT_IDThe first checkpoint id when an application is started and not recovered from a previously taken checkpoint or savepoint.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description JobInfogetJobInfo()Get the meta information of current job.OptionalLonggetRestoredCheckpointId()Returns id of the restored checkpoint, if state was restored from the snapshot of a previous execution.TaskInfogetTaskInfo()Get the meta information of current task.
-
-
-
Field Detail
-
INITIAL_CHECKPOINT_ID
static final long INITIAL_CHECKPOINT_ID
The first checkpoint id when an application is started and not recovered from a previously taken checkpoint or savepoint.- See Also:
- Constant Field Values
-
-
Method Detail
-
getRestoredCheckpointId
OptionalLong getRestoredCheckpointId()
Returns id of the restored checkpoint, if state was restored from the snapshot of a previous execution.
-
getJobInfo
@PublicEvolving JobInfo getJobInfo()
Get the meta information of current job.- Returns:
- the job meta information.
-
getTaskInfo
@PublicEvolving TaskInfo getTaskInfo()
Get the meta information of current task.- Returns:
- the task meta information.
-
-