public interface RecordSerializer<T extends IOReadableWritable>
Modifier and Type | Interface and Description |
---|---|
static class |
RecordSerializer.SerializationResult
Status of the serialization result.
|
Modifier and Type | Method and Description |
---|---|
RecordSerializer.SerializationResult |
copyToBufferBuilder(BufferBuilder bufferBuilder)
Copies the intermediate data serialization buffer to the given target buffer.
|
boolean |
hasSerializedData() |
void |
prune()
Clears the buffer and checks to decrease the size of intermediate data serialization buffer
after finishing the whole serialization process including
serializeRecord(IOReadableWritable) and copyToBufferBuilder(BufferBuilder) . |
void |
reset()
Supports copying an intermediate data serialization buffer to multiple target buffers
by resetting its initial position before each copying.
|
void |
serializeRecord(T record)
Starts serializing the given record to an intermediate data buffer.
|
void serializeRecord(T record) throws IOException
record
- the record to serializeIOException
RecordSerializer.SerializationResult copyToBufferBuilder(BufferBuilder bufferBuilder)
bufferBuilder
- the new target buffer to usevoid prune()
serializeRecord(IOReadableWritable)
and copyToBufferBuilder(BufferBuilder)
.void reset()
boolean hasSerializedData()
BufferBuilder
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.