org.apache.flink.connector.file.table.stream

Class TaskTracker

java.lang.Object

org.apache.flink.connector.file.table.stream.TaskTracker

@Internal
public class TaskTracker
extends Object

Track the upstream tasks to determine whether all the upstream data of a checkpoint has been received.

Constructor Summary

Constructors

Constructor and Description
TaskTracker(int numberOfTasks)

Method Summary

Modifier and Type	Method and Description
boolean	add(long checkpointId, int task)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskTracker

public TaskTracker(int numberOfTasks)

Method Detail

add

public boolean add(long checkpointId,
                   int task)

Returns:

true, if this checkpoint id need be committed.