Package io.deephaven.parquet.base

Class ColumnPageReaderImpl

java.lang.Object

io.deephaven.parquet.base.ColumnPageReaderImpl

All Implemented Interfaces:

ColumnPageReader, AutoCloseable

public class ColumnPageReaderImpl
extends Object
implements ColumnPageReader

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NULL_OFFSET

Method Summary

Modifier and Type	Method	Description
void	close()
@NotNull org.apache.parquet.column.Dictionary	getDictionary()
Object	materialize(Object nullValue)	Triggers the value decompression and decoding
long	numRows()
int	numValues()
IntBuffer	readKeyValues(IntBuffer keyDest, int nullPlaceholder)	Directly read the key integral values when there's a dictionary.
int	readRowCount()

Methods inherited from class java.lang.Object

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

Field Details

NULL_OFFSET

public static final int NULL_OFFSET

See Also:

• Constant Field Values

Method Details

materialize

public Object materialize(Object nullValue)
                   throws IOException

Description copied from interface: ColumnPageReader

Triggers the value decompression and decoding

Specified by:

materialize in interface ColumnPageReader

Parameters:

nullValue - The value to be stored under the null entries

Returns:

the data for that page in a format that makes sense for the given type - typically array of something that makes sense

Throws:

IOException

readRowCount

public int readRowCount()
                 throws IOException

Throws:

IOException

readKeyValues

public IntBuffer readKeyValues(IntBuffer keyDest,
 int nullPlaceholder)
                        throws IOException

Description copied from interface: ColumnPageReader

Directly read the key integral values when there's a dictionary.

Specified by:

readKeyValues in interface ColumnPageReader

Parameters:

keyDest - A properly sized buffer (at least numValues()) to hold the keys

nullPlaceholder - The value to use for nulls.

Returns:

A buffer holding the end of each repeated row. If the column is not repeating, null.

Throws:

IOException

numValues

public int numValues()
              throws IOException

Specified by:

numValues in interface ColumnPageReader

Returns:

The value stored under number DataPageHeader.num_values

Throws:

IOException

getDictionary

@NotNull
public @NotNull org.apache.parquet.column.Dictionary getDictionary()

Specified by:

getDictionary in interface ColumnPageReader

Returns:

Parquet dictionary for this column chunk

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

numRows

public long numRows()
             throws IOException

Specified by:

numRows in interface ColumnPageReader

Returns:

The number of rows in this ColumnChunk, or -1 if it's unknown.

Throws:

IOException