Uses of Interface
org.apache.flink.runtime.scheduler.slowtaskdetector.SlowTaskDetectorListener

Packages that use SlowTaskDetectorListener

Package	Description
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.slowtaskdetector

Uses of SlowTaskDetectorListener in org.apache.flink.runtime.scheduler.adaptivebatch

Classes in org.apache.flink.runtime.scheduler.adaptivebatch that implement SlowTaskDetectorListener

Modifier and Type	Class and Description
class	SpeculativeScheduler The speculative scheduler.

Uses of SlowTaskDetectorListener in org.apache.flink.runtime.scheduler.slowtaskdetector

Methods in org.apache.flink.runtime.scheduler.slowtaskdetector with parameters of type SlowTaskDetectorListener

Modifier and Type	Method and Description
void	SlowTaskDetector.start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor) Start detecting slow tasks periodically.
void	ExecutionTimeBasedSlowTaskDetector.start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor)