Package org.apache.druid.segment.data

Class LongsLongEncodingWriter

java.lang.Object

org.apache.druid.segment.data.LongsLongEncodingWriter

All Implemented Interfaces:

CompressionFactory.LongEncodingWriter

public class LongsLongEncodingWriter
extends Object
implements CompressionFactory.LongEncodingWriter

Constructor Summary

Constructors

Constructor	Description
LongsLongEncodingWriter(ByteOrder order)

Method Summary

Modifier and Type	Method	Description
void	flush()	Flush the unwritten content to the current output.
int	getBlockSize(int bytesPerBlock)	Get the number of values that can be encoded into each block for the given block size in bytes
int	getNumBytes(int values)	Get the number of bytes required to encoding the given number of values
int	metaSize()
void	putMeta(ByteBuffer metaOut, CompressionStrategy strategy)	Output the header values of the associating encoding format to the given outputStream.
void	setBuffer(ByteBuffer buffer)	Data will be written starting from current position of the buffer, and the position of the buffer will be updated as content is written.
void	setOutputStream(WriteOutBytes output)
void	write(long value)
void	write(long[] values, int offset, int length)

Methods inherited from class java.lang.Object

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

Constructor Details

LongsLongEncodingWriter

public LongsLongEncodingWriter(ByteOrder order)

Method Details

setBuffer

public void setBuffer(ByteBuffer buffer)

Description copied from interface: CompressionFactory.LongEncodingWriter

Data will be written starting from current position of the buffer, and the position of the buffer will be updated as content is written.

Specified by:

setBuffer in interface CompressionFactory.LongEncodingWriter

setOutputStream

public void setOutputStream(WriteOutBytes output)

Specified by:

setOutputStream in interface CompressionFactory.LongEncodingWriter

write

public void write(long value)
           throws IOException

Specified by:

write in interface CompressionFactory.LongEncodingWriter

Throws:

IOException

write

public void write(long[] values,
 int offset,
 int length)
           throws IOException

Specified by:

write in interface CompressionFactory.LongEncodingWriter

Throws:

IOException

flush

public void flush()

Description copied from interface: CompressionFactory.LongEncodingWriter

Flush the unwritten content to the current output.

Specified by:

flush in interface CompressionFactory.LongEncodingWriter

putMeta

public void putMeta(ByteBuffer metaOut,
 CompressionStrategy strategy)

Description copied from interface: CompressionFactory.LongEncodingWriter

Output the header values of the associating encoding format to the given outputStream. The header also include bytes for compression strategy and encoding format(optional) as described above in Compression Storage Format.

Specified by:

putMeta in interface CompressionFactory.LongEncodingWriter

metaSize

public int metaSize()

Specified by:

metaSize in interface CompressionFactory.LongEncodingWriter

getBlockSize

public int getBlockSize(int bytesPerBlock)

Description copied from interface: CompressionFactory.LongEncodingWriter

Get the number of values that can be encoded into each block for the given block size in bytes

Specified by:

getBlockSize in interface CompressionFactory.LongEncodingWriter

getNumBytes

public int getNumBytes(int values)

Description copied from interface: CompressionFactory.LongEncodingWriter

Get the number of bytes required to encoding the given number of values

Specified by:

getNumBytes in interface CompressionFactory.LongEncodingWriter