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
-
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, org.apache.parquet.bytes.ByteBufferAllocator allocator)
DeltaBinaryPackingValuesWriterForLong(int slabSize, int pageSize, org.apache.parquet.bytes.ByteBufferAllocator allocator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Called to close the values writer.org.apache.parquet.bytes.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 pagevoid
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
-
-
-
-
Constructor Detail
-
DeltaBinaryPackingValuesWriterForLong
public DeltaBinaryPackingValuesWriterForLong(int slabSize, int pageSize, org.apache.parquet.bytes.ByteBufferAllocator allocator)
-
DeltaBinaryPackingValuesWriterForLong
public DeltaBinaryPackingValuesWriterForLong(int blockSizeInValues, int miniBlockNum, int slabSize, int pageSize, org.apache.parquet.bytes.ByteBufferAllocator allocator)
-
-
Method Detail
-
writeLong
public void writeLong(long v)
- Overrides:
writeLong
in classValuesWriter
- Parameters:
v
- the value to encode
-
getBytes
public org.apache.parquet.bytes.BytesInput getBytes()
getBytes will trigger flushing block buffer, DO NOT write after getBytes() is called without calling reset()- Specified by:
getBytes
in classValuesWriter
- 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 classDeltaBinaryPackingValuesWriter
-
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.- Overrides:
close
in classDeltaBinaryPackingValuesWriter
-
-