Package org.apache.druid.segment.data

Class TableLongEncodingWriter

java.lang.Object

org.apache.druid.segment.data.TableLongEncodingWriter

All Implemented Interfaces:

CompressionFactory.LongEncodingWriter

public class TableLongEncodingWriter
extends Object
implements CompressionFactory.LongEncodingWriter

Constructor Summary

Constructors

Constructor	Description
TableLongEncodingWriter(it.unimi.dsi.fastutil.longs.Long2IntMap table, it.unimi.dsi.fastutil.longs.LongList valueAddedInOrder)

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)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.segment.data.CompressionFactory.LongEncodingWriter

write

Constructor Details

TableLongEncodingWriter

public TableLongEncodingWriter(it.unimi.dsi.fastutil.longs.Long2IntMap table,
 it.unimi.dsi.fastutil.longs.LongList valueAddedInOrder)

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

flush

public void flush()
           throws IOException

Description copied from interface: CompressionFactory.LongEncodingWriter

Flush the unwritten content to the current output.

Specified by:

flush in interface CompressionFactory.LongEncodingWriter

Throws:

IOException

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