Modifier and Type | Method and Description |
---|---|
void |
SplitEnumeratorContext.assignSplits(SplitsAssignment<SplitT> newSplitAssignments)
Assign the splits.
|
Modifier and Type | Method and Description |
---|---|
Optional<SplitsAssignment<PulsarPartitionSplit>> |
SplitAssigner.createAssignment(List<Integer> readers)
Create a split assignment from the current readers.
|
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–2023 The Apache Software Foundation. All rights reserved.