public interface RecordSerializer<T extends IOReadableWritable>
Modifier and Type | Interface and Description |
---|---|
static class |
RecordSerializer.SerializationResult |
Modifier and Type | Method and Description |
---|---|
RecordSerializer.SerializationResult |
addRecord(T record) |
void |
clear() |
void |
clearCurrentBuffer() |
Buffer |
getCurrentBuffer() |
boolean |
hasData() |
RecordSerializer.SerializationResult |
setNextBuffer(Buffer buffer) |
void |
setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
RecordSerializer.SerializationResult addRecord(T record) throws IOException
IOException
RecordSerializer.SerializationResult setNextBuffer(Buffer buffer) throws IOException
IOException
Buffer getCurrentBuffer()
void clearCurrentBuffer()
void clear()
boolean hasData()
void setReporter(AccumulatorRegistry.Reporter reporter)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.