public class V3CompressedVSizeColumnarMultiIntsSupplier extends Object implements WritableSupplier<ColumnarMultiInts>
CompressedVSizeColumnarMultiIntsSupplier
(which has version 0x2, so we
call it V2), the only difference is V3's offsets is not VSize encoded, it's just compressed.
The reason we provide this is we can streams the data out in the binary format with V3CompressedVSizeColumnarMultiIntsSerializer
.
If we want to streams VSizeInts, we must know the max value in the value sets. It's easy to know the max id of
values(like dimension cardinality while encoding dimension), but difficult to known the max id of offsets.Modifier and Type | Field and Description |
---|---|
static byte |
VERSION |
Modifier and Type | Method and Description |
---|---|
static V3CompressedVSizeColumnarMultiIntsSupplier |
fromByteBuffer(ByteBuffer buffer,
ByteOrder order) |
static V3CompressedVSizeColumnarMultiIntsSupplier |
fromIterable(Iterable<IndexedInts> objectsIterable,
int offsetChunkFactor,
int maxValue,
ByteOrder byteOrder,
CompressionStrategy compression,
Closer closer) |
ColumnarMultiInts |
get() |
long |
getSerializedSize()
Returns the number of bytes, that this Serializer will write to the output _channel_ (not smoosher) on a
Serializer.writeTo(java.nio.channels.WritableByteChannel, io.druid.java.util.common.io.smoosh.FileSmoosher) call. |
void |
writeTo(WritableByteChannel channel,
FileSmoosher smoosher)
Writes serialized form of this object to the given channel.
|
public static final byte VERSION
public static V3CompressedVSizeColumnarMultiIntsSupplier fromByteBuffer(ByteBuffer buffer, ByteOrder order)
public static V3CompressedVSizeColumnarMultiIntsSupplier fromIterable(Iterable<IndexedInts> objectsIterable, int offsetChunkFactor, int maxValue, ByteOrder byteOrder, CompressionStrategy compression, Closer closer)
public long getSerializedSize() throws IOException
Serializer
Serializer.writeTo(java.nio.channels.WritableByteChannel, io.druid.java.util.common.io.smoosh.FileSmoosher)
call.getSerializedSize
in interface Serializer
IOException
public void writeTo(WritableByteChannel channel, FileSmoosher smoosher) throws IOException
Serializer
writeTo
in interface Serializer
IOException
public ColumnarMultiInts get()
get
in interface com.google.common.base.Supplier<ColumnarMultiInts>
Copyright © 2011–2018. All rights reserved.