Package io.deephaven.parquet.base

Class ColumnWriterImpl

java.lang.Object

io.deephaven.parquet.base.ColumnWriterImpl

All Implemented Interfaces:

SafeCloseable, ColumnWriter, AutoCloseable

public class ColumnWriterImpl
extends Object
implements ColumnWriter

Method Summary

Modifier and Type	Method	Description
void	addDictionaryPage(@NotNull Object dictionaryValues, int valuesCount)	Add a page of dictionary data to the column.
void	addPage(@NotNull Object pageData, int valuesCount)	Add a page of values which may contain null values.
void	addPageNoNulls(@NotNull Object pageData, int valuesCount)	Add a page of data that does not contain null values.
void	addVectorPage(@NotNull Object pageData, @NotNull IntBuffer repeatCount, int nonNullValueCount)	Encode a page of vector values.
void	close()
org.apache.parquet.column.ColumnDescriptor	getColumn()
org.apache.parquet.internal.column.columnindex.OffsetIndex	getOffsetIndex()
@NotNull org.apache.parquet.column.statistics.Statistics<?>	getStatistics()	Get the Statistics object into which to encode min/max/null count information for the footer.
void	writeDictionaryPage(ByteBuffer dictionaryBuffer, int valuesCount)

Methods inherited from class java.lang.Object

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

Method Details

addPageNoNulls

public void addPageNoNulls(@NotNull
 @NotNull Object pageData,
 int valuesCount)
                    throws IOException

Description copied from interface: ColumnWriter

Add a page of data that does not contain null values.

Specified by:

addPageNoNulls in interface ColumnWriter

Parameters:

pageData - the raw page data

valuesCount - the count of values in the page.

Throws:

IOException - if there is an error writing values.

addDictionaryPage

public void addDictionaryPage(@NotNull
 @NotNull Object dictionaryValues,
 int valuesCount)
                       throws IOException

Description copied from interface: ColumnWriter

Add a page of dictionary data to the column.

Specified by:

addDictionaryPage in interface ColumnWriter

Parameters:

dictionaryValues - the values in the dictionary

valuesCount - the count of values

Throws:

IOException - if there is an error writing dictionary values.

writeDictionaryPage

public void writeDictionaryPage(ByteBuffer dictionaryBuffer,
 int valuesCount)
                         throws IOException

Throws:

IOException

addPage

public void addPage(@NotNull
 @NotNull Object pageData,
 int valuesCount)
             throws IOException

Description copied from interface: ColumnWriter

Add a page of values which may contain null values.

Specified by:

addPage in interface ColumnWriter

Parameters:

pageData - the raw page data.

valuesCount - the total count of items

Throws:

IOException - if there is an error writing values.

addVectorPage

public void addVectorPage(@NotNull
 @NotNull Object pageData,
 @NotNull
 @NotNull IntBuffer repeatCount,
 int nonNullValueCount)
                   throws IOException

Description copied from interface: ColumnWriter

Encode a page of vector values.

Specified by:

addVectorPage in interface ColumnWriter

Parameters:

pageData - the raw flattened page data

repeatCount - an int buffer where each int is the length of a single source vector.

nonNullValueCount - the total number of vectors to encode

Throws:

IOException - if there is an error writing values.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

getColumn

public org.apache.parquet.column.ColumnDescriptor getColumn()

getOffsetIndex

public org.apache.parquet.internal.column.columnindex.OffsetIndex getOffsetIndex()

getStatistics

@NotNull
public @NotNull org.apache.parquet.column.statistics.Statistics<?> getStatistics()

Description copied from interface: ColumnWriter

Get the Statistics object into which to encode min/max/null count information for the footer.

Specified by:

getStatistics in interface ColumnWriter

Returns:

the statistics object