Package org.apache.druid.segment.serde.cell

Class CellReader.Builder

java.lang.Object

org.apache.druid.segment.serde.cell.CellReader.Builder

Enclosing class:

CellReader

public static class CellReader.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder(ByteBuffer originalByteBuffer)	The default block size is 64k as provided by NativeClearedByteBufferProvider.

Method Summary

Modifier and Type	Method	Description
CellReader	build()
CellReader.Builder	setByteBufferProvider(ByteBufferProvider byteBufferProvider)
CellReader.Builder	setCompressionStrategy(CompressionStrategy compressionStrategy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Builder

public Builder(ByteBuffer originalByteBuffer)

The default block size is 64k as provided by NativeClearedByteBufferProvider. You may change this, but be sure the size of the ByteBuffers match what the CelLWriter used as this is the block size stored. All reading will fail unpredictably if a different block size is used when reading

Parameters:

originalByteBuffer - - buffer from CellWriter.writeTo() as written to the WritableChannel

Method Details

setCompressionStrategy

public CellReader.Builder setCompressionStrategy(CompressionStrategy compressionStrategy)

Parameters:

compressionStrategy - - this must match the CellWriter compressionStrategy. Default LZ4

Returns:

setByteBufferProvider

public CellReader.Builder setByteBufferProvider(ByteBufferProvider byteBufferProvider)

Parameters:

byteBufferProvider - - ByteBuffers returned must match the size used in the CellWriter

Returns:

Builder

build

public CellReader build()