org.apache.flink.runtime.executiongraph

Interface JobStatusProvider

All Known Subinterfaces:

AccessExecutionGraph, ExecutionGraph

All Known Implementing Classes:

ArchivedExecutionGraph, DefaultExecutionGraph, JobStatusStore

public interface JobStatusProvider

Interface for querying the state of a job and the timestamps of state transitions.

Method Summary

Modifier and Type	Method and Description
JobStatus	getState() Returns the current JobStatus for this execution graph.
long	getStatusTimestamp(JobStatus status) Returns the timestamp for the given JobStatus.

Method Detail

getState

JobStatus getState()

Returns the current JobStatus for this execution graph.

Returns:

job status for this execution graph

getStatusTimestamp

long getStatusTimestamp(JobStatus status)

Returns the timestamp for the given JobStatus.

Parameters:

status - status for which the timestamp should be returned

Returns:

timestamp for the given job status