io.druid.segment.data

Interface CompressionFactory.LongEncodingWriter

All Known Implementing Classes:

DeltaLongEncodingWriter, LongsLongEncodingWriter, TableLongEncodingWriter

Enclosing class:

CompressionFactory

public static interface CompressionFactory.LongEncodingWriter

This writer output encoded values to the given ByteBuffer or OutputStream. setBuffer(ByteBuffer) or setOutputStream(OutputStream) must be called before any value is written, and flush() must be called before calling setBuffer or setOutputStream again to set another output.

Method Summary

Modifier and Type	Method and 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
void	putMeta(OutputStream metaOut, CompressedObjectStrategy.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(OutputStream output)
void	write(long value)

Method Detail

setBuffer

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.

setOutputStream

void setOutputStream(OutputStream output)

write

void write(long value)
    throws IOException

Throws:

IOException

flush

void flush()
    throws IOException

Flush the unwritten content to the current output.

Throws:

IOException

putMeta

void putMeta(OutputStream metaOut,
             CompressedObjectStrategy.CompressionStrategy strategy)
      throws IOException

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.

Throws:

IOException

getBlockSize

int getBlockSize(int bytesPerBlock)

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

getNumBytes

int getNumBytes(int values)

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