Package | Description |
---|---|
org.apache.flink.api.connector.source | |
org.apache.flink.connector.testutils.source.reader | |
org.apache.flink.runtime.source.coordinator |
Modifier and Type | Method and Description |
---|---|
void |
SplitEnumeratorContext.assignSplits(SplitsAssignment<SplitT> newSplitAssignments)
Assign the splits.
|
Modifier and Type | Method and Description |
---|---|
void |
TestingSplitEnumeratorContext.assignSplits(SplitsAssignment<SplitT> newSplitAssignments) |
Modifier and Type | Method and Description |
---|---|
void |
SourceCoordinatorContext.assignSplits(SplitsAssignment<SplitT> assignment) |
void |
SplitAssignmentTracker.recordSplitAssignment(SplitsAssignment<SplitT> splitsAssignment)
Record a new split assignment.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.