SplitsRemoval (Flink : Connectors : Base 1.20.1-cp2 API)

java.lang.Object
- org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<SplitT>
- - org.apache.flink.connector.base.source.reader.splitreader.SplitsRemoval<SplitT>

Type Parameters:

SplitT - the split type.
```
@Internal
public class SplitsRemoval<SplitT>
extends SplitsChange<SplitT>
```
A change to remove splits.
This type of SplitsChange is only used when the RecordEvaluator reports the end of the stream.
The SplitsRemoval change between the enumerator and the reader may cause a data loss. See more details at the discussion e-mail.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  SplitsRemoval(List<SplitT> splits)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  String toString()
  - Methods inherited from class org.apache.flink.connector.base.source.reader.splitreader.SplitsChange
    splits
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - SplitsRemoval
```
public SplitsRemoval(List<SplitT> splits)
```
- Method Detail
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object