Interface InitContext

    • 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.