TaskTracker (Flink : Connectors : Files 2.2.0 API)

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 Description
  
  TaskTracker(int numberOfTasks)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method 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.