ExecutionTimeBasedSlowTaskDetector (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.scheduler.slowtaskdetector.ExecutionTimeBasedSlowTaskDetector

All Implemented Interfaces:

SlowTaskDetector
```
public class ExecutionTimeBasedSlowTaskDetector
extends Object
implements SlowTaskDetector
```
The slow task detector which detects slow tasks based on their execution time.

Constructor Summary

Constructors
Constructor Description

ExecutionTimeBasedSlowTaskDetector(Configuration configuration)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor)`	Start detecting slow tasks periodically.
`void`	`stop()`	Stop detecting slow tasks.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ExecutionTimeBasedSlowTaskDetector
```
public ExecutionTimeBasedSlowTaskDetector(Configuration configuration)
```
- Method Detail
  - start
```
public void start(ExecutionGraph executionGraph,
                  SlowTaskDetectorListener listener,
                  ComponentMainThreadExecutor mainThreadExecutor)
```
    Description copied from interface: SlowTaskDetector
    
    Start detecting slow tasks periodically.
    
    Specified by:
    
    start in interface SlowTaskDetector
  - stop
```
public void stop()
```
    Description copied from interface: SlowTaskDetector
    
    Stop detecting slow tasks.
    
    Specified by:
    
    stop in interface SlowTaskDetector