public interface RecordDeserializer<T extends IOReadableWritable>
Modifier and Type | Interface and Description |
---|---|
static class |
RecordDeserializer.DeserializationResult |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
Buffer |
getCurrentBuffer() |
RecordDeserializer.DeserializationResult |
getNextRecord(T target) |
boolean |
hasUnfinishedData() |
void |
setNextBuffer(Buffer buffer) |
void |
setNextMemorySegment(MemorySegment segment,
int numBytes) |
void |
setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
RecordDeserializer.DeserializationResult getNextRecord(T target) throws IOException
IOException
void setNextMemorySegment(MemorySegment segment, int numBytes) throws IOException
IOException
void setNextBuffer(Buffer buffer) throws IOException
IOException
Buffer getCurrentBuffer()
void clear()
boolean hasUnfinishedData()
void setReporter(AccumulatorRegistry.Reporter reporter)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.