io.druid.segment.data

Class CompressedLongsSupplierSerializer

java.lang.Object

io.druid.segment.data.CompressedLongsSupplierSerializer

public class CompressedLongsSupplierSerializer
extends Object

Constructor Summary

Constructors

Constructor and Description
CompressedLongsSupplierSerializer(int sizePer, GenericIndexedWriter<ResourceHolder<LongBuffer>> flattener, CompressedObjectStrategy.CompressionStrategy compression)

Method Summary

Modifier and Type	Method and Description
void	add(long value)
void	close()
void	closeAndConsolidate(com.google.common.io.OutputSupplier<? extends OutputStream> consolidatedOut)
static CompressedLongsSupplierSerializer	create(IOPeon ioPeon, String filenameBase, ByteOrder order, CompressedObjectStrategy.CompressionStrategy compression)
long	getSerializedSize()
void	open()
int	size()
void	writeToChannel(WritableByteChannel channel)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompressedLongsSupplierSerializer

public CompressedLongsSupplierSerializer(int sizePer,
                                         GenericIndexedWriter<ResourceHolder<LongBuffer>> flattener,
                                         CompressedObjectStrategy.CompressionStrategy compression)

Method Detail

create

public static CompressedLongsSupplierSerializer create(IOPeon ioPeon,
                                                       String filenameBase,
                                                       ByteOrder order,
                                                       CompressedObjectStrategy.CompressionStrategy compression)
                                                throws IOException

Throws:

IOException

open

public void open()
          throws IOException

Throws:

IOException

size

public int size()

add

public void add(long value)
         throws IOException

Throws:

IOException

closeAndConsolidate

public void closeAndConsolidate(com.google.common.io.OutputSupplier<? extends OutputStream> consolidatedOut)
                         throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

getSerializedSize

public long getSerializedSize()

writeToChannel

public void writeToChannel(WritableByteChannel channel)
                    throws IOException

Throws:

IOException