public interface RecordDeserializer<T extends IOReadableWritable>
Modifier and Type | Interface and Description |
---|---|
static class |
RecordDeserializer.DeserializationResult
Status of the deserialization result.
|
Modifier and Type | Method and Description |
---|---|
void |
clear() |
Buffer |
getCurrentBuffer() |
RecordDeserializer.DeserializationResult |
getNextRecord(T target) |
CloseableIterator<Buffer> |
getUnconsumedBuffer()
Gets the unconsumed buffer which needs to be persisted in unaligned checkpoint scenario.
|
boolean |
hasUnfinishedData() |
void |
setNextBuffer(Buffer buffer) |
RecordDeserializer.DeserializationResult getNextRecord(T target) throws IOException
IOException
void setNextBuffer(Buffer buffer) throws IOException
IOException
Buffer getCurrentBuffer()
void clear()
boolean hasUnfinishedData()
CloseableIterator<Buffer> getUnconsumedBuffer() throws IOException
Note that the unconsumed buffer might be null if the whole buffer was already consumed before and there are no partial length or data remained in the end of buffer.
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.