Package io.deephaven.parquet.table.transfer

Class ArrayAndVectorTransfer<COLUMN_TYPE,ENCODED_COLUMN_TYPE,BUFFER_TYPE>

java.lang.Object

io.deephaven.parquet.table.transfer.ArrayAndVectorTransfer<COLUMN_TYPE,ENCODED_COLUMN_TYPE,BUFFER_TYPE>

All Implemented Interfaces:

TransferObject<BUFFER_TYPE>, SafeCloseable, AutoCloseable

Direct Known Subclasses:

DictEncodedStringArrayAndVectorTransfer

public abstract class ArrayAndVectorTransfer<COLUMN_TYPE,ENCODED_COLUMN_TYPE,BUFFER_TYPE>
extends Object

Base class for all array and vector transfer objects

Method Summary

Modifier and Type	Method	Description
final void	close()
final BUFFER_TYPE	getBuffer()	Get the buffer suitable for writing to a Parquet file
final IntBuffer	getRepeatCount()	Get the lengths of array/vector elements added to the buffer.
final boolean	hasMoreDataToBuffer()	Check if there is any more data which can be copied into buffer

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.parquet.table.transfer.TransferObject

pageHasNull, transferOnePageToBuffer

Method Details

getRepeatCount

public final IntBuffer getRepeatCount()

Description copied from interface: TransferObject

Get the lengths of array/vector elements added to the buffer.

Returns:

the buffer with counts

getBuffer

public final BUFFER_TYPE getBuffer()

Description copied from interface: TransferObject

Get the buffer suitable for writing to a Parquet file

Specified by:

getBuffer in interface TransferObject<COLUMN_TYPE>

Returns:

the buffer

hasMoreDataToBuffer

public final boolean hasMoreDataToBuffer()

Description copied from interface: TransferObject

Check if there is any more data which can be copied into buffer

Specified by:

hasMoreDataToBuffer in interface TransferObject<COLUMN_TYPE>

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable