org.apache.flink.api.connector.source

Class SplitsAssignment<SplitT extends SourceSplit>

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 and Description
SplitsAssignment(Map<Integer,List<SplitT>> assignment)
SplitsAssignment(SplitT split, int subtask)

Method Summary

Modifier and Type	Method and 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