public class FIFOSplitAssigner extends Object implements SplitAssigner
Constructor and Description |
---|
FIFOSplitAssigner(Collection<FileStoreSourceSplit> splits) |
Modifier and Type | Method and Description |
---|---|
void |
addSplit(int suggestedTask,
FileStoreSourceSplit split)
Add one split of a specified subtask to the assigner.
|
void |
addSplitsBack(int subtask,
List<FileStoreSourceSplit> splits)
Adds a set of splits to this assigner.
|
List<FileStoreSourceSplit> |
getNext(int subtask,
String hostname)
Gets the next split.
|
Optional<Long> |
getNextSnapshotId(int subtask)
Gets the snapshot id of the next split.
|
int |
numberOfRemainingSplits()
Gets the current number of remaining splits.
|
Collection<FileStoreSourceSplit> |
remainingSplits()
Gets the remaining splits that this assigner has pending.
|
public FIFOSplitAssigner(Collection<FileStoreSourceSplit> splits)
public List<FileStoreSourceSplit> getNext(int subtask, @Nullable String hostname)
SplitAssigner
When this method returns an empty Optional
, then the set of splits is assumed to
be done and the source will finish once the readers finished their current splits.
getNext
in interface SplitAssigner
public void addSplit(int suggestedTask, FileStoreSourceSplit split)
SplitAssigner
addSplit
in interface SplitAssigner
public void addSplitsBack(int subtask, List<FileStoreSourceSplit> splits)
SplitAssigner
addSplitsBack
in interface SplitAssigner
public Collection<FileStoreSourceSplit> remainingSplits()
SplitAssigner
remainingSplits
in interface SplitAssigner
public Optional<Long> getNextSnapshotId(int subtask)
SplitAssigner
getNextSnapshotId
in interface SplitAssigner
public int numberOfRemainingSplits()
SplitAssigner
numberOfRemainingSplits
in interface SplitAssigner
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.