io.druid.segment.data

Class CompressedFloatsSupplierSerializer

java.lang.Object

io.druid.segment.data.CompressedFloatsSupplierSerializer

public class CompressedFloatsSupplierSerializer
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	add(float value)
void	close()
void	closeAndConsolidate(com.google.common.io.OutputSupplier<? extends OutputStream> consolidatedOut)
static CompressedFloatsSupplierSerializer	create(IOPeon ioPeon, String filenameBase, ByteOrder order, CompressedObjectStrategy.CompressionStrategy compression)
static CompressedFloatsSupplierSerializer	create(IOPeon ioPeon, String filenameBase, int sizePer, 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

CompressedFloatsSupplierSerializer

public CompressedFloatsSupplierSerializer(int sizePer,
                                          GenericIndexedWriter<ResourceHolder<FloatBuffer>> flattener,
                                          CompressedObjectStrategy.CompressionStrategy compression)

Method Detail

create

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

Throws:

IOException

create

public static CompressedFloatsSupplierSerializer create(IOPeon ioPeon,
                                                        String filenameBase,
                                                        int sizePer,
                                                        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(float 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