SplitsAssignment (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.connector.source.SplitsAssignment<SplitT>

```
@Public
public final class SplitsAssignment<SplitT extends SourceSplit>
extends Object
```
A class containing the splits assignment to the source readers.
The assignment is always incremental. In another word, splits in the assignment are simply added to the existing assignment.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  SplitsAssignment(Map<Integer,List<SplitT>> assignment)
  
  SplitsAssignment(SplitT split, int subtask)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  Map<Integer,List<SplitT>> assignment()
  
  String toString()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SplitsAssignment

public SplitsAssignment(Map<Integer,List<SplitT>> assignment)

SplitsAssignment

public SplitsAssignment(SplitT split,
                        int subtask)

Method Detail
- assignment
```
public Map<Integer,List<SplitT>> assignment()
```
  Returns:
  
  A mapping from subtask ID to their split assignment.
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object