T
- The type of the records that are serialized.public class SpanningRecordSerializer<T extends IOReadableWritable> extends Object implements RecordSerializer<T>
copyToBufferBuilder(BufferBuilder)
.RecordSerializer.SerializationResult
Constructor and Description |
---|
SpanningRecordSerializer() |
Modifier and Type | Method and Description |
---|---|
RecordSerializer.SerializationResult |
copyToBufferBuilder(BufferBuilder targetBuffer)
Copies an intermediate data serialization buffer into the target BufferBuilder.
|
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
RecordSerializer.serializeRecord(IOReadableWritable) and RecordSerializer.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)
Serializes the complete record to an intermediate data serialization buffer.
|
public void serializeRecord(T record) throws IOException
serializeRecord
in interface RecordSerializer<T extends IOReadableWritable>
record
- the record to serializeIOException
public RecordSerializer.SerializationResult copyToBufferBuilder(BufferBuilder targetBuffer)
copyToBufferBuilder
in interface RecordSerializer<T extends IOReadableWritable>
targetBuffer
- the target BufferBuilder to copy topublic void reset()
RecordSerializer
reset
in interface RecordSerializer<T extends IOReadableWritable>
public void prune()
RecordSerializer
RecordSerializer.serializeRecord(IOReadableWritable)
and RecordSerializer.copyToBufferBuilder(BufferBuilder)
.prune
in interface RecordSerializer<T extends IOReadableWritable>
public boolean hasSerializedData()
hasSerializedData
in interface RecordSerializer<T extends IOReadableWritable>
BufferBuilder
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.