Package org.apache.parquet.column.values.delta

Class DeltaBinaryPackingValuesWriterForLong

java.lang.Object

org.apache.parquet.column.values.ValuesWriter

org.apache.parquet.column.values.delta.DeltaBinaryPackingValuesWriter

org.apache.parquet.column.values.delta.DeltaBinaryPackingValuesWriterForLong

All Implemented Interfaces:

AutoCloseable

public class DeltaBinaryPackingValuesWriterForLong
extends DeltaBinaryPackingValuesWriter

Write longs (INT64) with delta encoding and binary packing.

Field Summary

Fields inherited from class org.apache.parquet.column.values.delta.DeltaBinaryPackingValuesWriter

baos, bitWidths, config, DEFAULT_NUM_BLOCK_VALUES, DEFAULT_NUM_MINIBLOCKS, deltaValuesToFlush, miniBlockByteBuffer, totalValueCount

Constructor Summary

Constructors

Constructor	Description
DeltaBinaryPackingValuesWriterForLong(int blockSizeInValues, int miniBlockNum, int slabSize, int pageSize, ByteBufferAllocator allocator)
DeltaBinaryPackingValuesWriterForLong(int slabSize, int pageSize, ByteBufferAllocator allocator)

Method Summary

Modifier and Type	Method	Description
void	close()	Called to close the values writer.
BytesInput	getBytes()	getBytes will trigger flushing block buffer, DO NOT write after getBytes() is called without calling reset()
void	reset()	called after getBytes() to reset the current buffer and start writing the next page
void	writeLong(long v)

Methods inherited from class org.apache.parquet.column.values.delta.DeltaBinaryPackingValuesWriter

getAllocatedSize, getBufferedSize, getEncoding, getMiniBlockCountToFlush, memUsageString, writeBitWidthForMiniBlock

Methods inherited from class org.apache.parquet.column.values.ValuesWriter

resetDictionary, toDictPageAndClose, writeBoolean, writeByte, writeBytes, writeDouble, writeFloat, writeInteger

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaBinaryPackingValuesWriterForLong

public DeltaBinaryPackingValuesWriterForLong(int slabSize,
                                             int pageSize,
                                             ByteBufferAllocator allocator)

DeltaBinaryPackingValuesWriterForLong

public DeltaBinaryPackingValuesWriterForLong(int blockSizeInValues,
                                             int miniBlockNum,
                                             int slabSize,
                                             int pageSize,
                                             ByteBufferAllocator allocator)

Method Detail

writeLong

public void writeLong(long v)

Overrides:

writeLong in class ValuesWriter

Parameters:

v - the value to encode

getBytes

public BytesInput getBytes()

getBytes will trigger flushing block buffer, DO NOT write after getBytes() is called without calling reset()

Specified by:

getBytes in class ValuesWriter

Returns:

a BytesInput that contains the encoded page data

reset

public void reset()

Description copied from class: ValuesWriter

called after getBytes() to reset the current buffer and start writing the next page

Overrides:

reset in class DeltaBinaryPackingValuesWriter

close

public void close()

Description copied from class: ValuesWriter

Called to close the values writer. Any output stream is closed and can no longer be used. All resources are released.

Specified by:

close in interface AutoCloseable

Overrides:

close in class DeltaBinaryPackingValuesWriter