public interface RecordsWithSplitIds<E>
Modifier and Type | Method and Description |
---|---|
Set<String> |
finishedSplits()
Get the finished splits.
|
E |
nextRecordFromSplit()
Gets the next record from the current split.
|
String |
nextSplit()
Moves to the next split.
|
default void |
recycle()
This method is called when all records from this batch have been emitted.
|
@Nullable String nextSplit()
@Nullable E nextRecordFromSplit()
Set<String> finishedSplits()
default void recycle()
Overriding this method gives implementations the opportunity to recycle/reuse this object, which is a performance optimization that is important for cases where the record objects are large or otherwise heavy to allocate.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.