Package org.apache.flink.runtime.executiongraph

Interface ExecutionStateUpdateListener

All Known Subinterfaces:

ExecutionStatusMetricsRegistrar

All Known Implementing Classes:

AllSubTasksRunningOrFinishedStateTimeMetrics, DeploymentStateTimeMetrics

public interface ExecutionStateUpdateListener

A listener that is called when an execution switched to a new state.

Method Summary

Modifier and Type	Method	Description
static ExecutionStateUpdateListener	combine(ExecutionStateUpdateListener... listeners)
void	onStateUpdate(ExecutionAttemptID execution, ExecutionState previousState, ExecutionState newState)

Method Detail

onStateUpdate

void onStateUpdate(ExecutionAttemptID execution,
                   ExecutionState previousState,
                   ExecutionState newState)

combine

static ExecutionStateUpdateListener combine(ExecutionStateUpdateListener... listeners)