io.druid.segment.data

Class CompressedIntsIndexedWriter

java.lang.Object

io.druid.segment.data.SingleValueIndexedIntsWriter

io.druid.segment.data.CompressedIntsIndexedWriter

All Implemented Interfaces:

IndexedIntsWriter, Closeable, AutoCloseable

public class CompressedIntsIndexedWriter
extends SingleValueIndexedIntsWriter

Streams array of integers out in the binary format described by CompressedIntsIndexedSupplier

Constructor Summary

Constructors

Constructor and Description
CompressedIntsIndexedWriter(int chunkFactor, CompressedObjectStrategy.CompressionStrategy compression, GenericIndexedWriter<ResourceHolder<IntBuffer>> flattner)
CompressedIntsIndexedWriter(IOPeon ioPeon, String filenameBase, int chunkFactor, ByteOrder byteOrder, CompressedObjectStrategy.CompressionStrategy compression)

Method Summary

Modifier and Type	Method and Description
protected void	addValue(int val)
void	close()
static CompressedIntsIndexedWriter	create(IOPeon ioPeon, String filenameBase, CompressedObjectStrategy.CompressionStrategy compression)
long	getSerializedSize()
void	open()
void	writeToChannel(WritableByteChannel channel, FileSmoosher smoosher)

Methods inherited from class io.druid.segment.data.SingleValueIndexedIntsWriter

add

Methods inherited from class java.lang.Object

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

Constructor Detail

CompressedIntsIndexedWriter

public CompressedIntsIndexedWriter(IOPeon ioPeon,
                                   String filenameBase,
                                   int chunkFactor,
                                   ByteOrder byteOrder,
                                   CompressedObjectStrategy.CompressionStrategy compression)

CompressedIntsIndexedWriter

public CompressedIntsIndexedWriter(int chunkFactor,
                                   CompressedObjectStrategy.CompressionStrategy compression,
                                   GenericIndexedWriter<ResourceHolder<IntBuffer>> flattner)

Method Detail

create

public static CompressedIntsIndexedWriter create(IOPeon ioPeon,
                                                 String filenameBase,
                                                 CompressedObjectStrategy.CompressionStrategy compression)

open

public void open()
          throws IOException

Throws:

IOException

addValue

protected void addValue(int val)
                 throws IOException

Specified by:

addValue in class SingleValueIndexedIntsWriter

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

getSerializedSize

public long getSerializedSize()

writeToChannel

public void writeToChannel(WritableByteChannel channel,
                           FileSmoosher smoosher)
                    throws IOException

Throws:

IOException