RemoveSplitsTask (Flink : Connectors : Base 2.1.1-cp1 API)

java.lang.Object
- org.apache.flink.connector.base.source.reader.fetcher.RemoveSplitsTask<SplitT>

All Implemented Interfaces:: SplitFetcherTask

@Internal
public class RemoveSplitsTask<SplitT extends org.apache.flink.api.connector.source.SourceSplit>
extends Object
implements SplitFetcherTask

The task to finish reading some splits.

- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  boolean run()
  Run the logic.
  
  String toString()
  
  void wakeUp()
  Wake up the running thread.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Method Detail
  - run
```
public boolean run()
```
    Description copied from interface: SplitFetcherTask
    
    Run the logic. This method allows throwing an interrupted exception on wakeup, but the implementation does not have to. It is preferred to finish the work elegantly and return a boolean to indicate whether all the jobs have been done or more invocation is needed.
    
    Specified by:
    
    run in interface SplitFetcherTask
    
    Returns:
    
    whether the runnable has successfully finished running.
  - wakeUp
```
public void wakeUp()
```
    Description copied from interface: SplitFetcherTask
    
    Wake up the running thread.
    
    Specified by:
    
    wakeUp in interface SplitFetcherTask
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object