E
- the element type.SplitT
- the split type.public interface SplitReader<E,SplitT extends SourceSplit>
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the split reader.
|
RecordsWithSplitIds<E> |
fetch()
Fetch elements into the blocking queue for the given splits.
|
void |
handleSplitsChanges(SplitsChange<SplitT> splitsChanges)
Handle the split changes.
|
void |
wakeUp()
Wake up the split reader in case the fetcher thread is blocking in
fetch() . |
RecordsWithSplitIds<E> fetch() throws IOException
wakeUp()
is invoked. In that case, the
implementation may either decide to return without throwing an exception, or it can just
throw an interrupted exception. In either case, this method should be reentrant, meaning that
the next fetch call should just resume from where the last fetch call was waken up or
interrupted.IOException
- when encountered IO errors, such as deserialization failures.void handleSplitsChanges(SplitsChange<SplitT> splitsChanges)
splitsChanges
- the split changes that the SplitReader needs to handle.void wakeUp()
fetch()
.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.