Package io.deephaven.parquet.table.pagestore

Class ColumnChunkPageStore<ATTR extends Any>

java.lang.Object

io.deephaven.parquet.table.pagestore.ColumnChunkPageStore<ATTR>

All Implemented Interfaces:

Page<ATTR>, PageStore<ATTR,ATTR,ChunkPage<ATTR>>, PagingChunkSource<ATTR>, ChunkSource<ATTR>, FillContextMaker, GetContextMaker, DefaultChunkSource<ATTR>, DefaultChunkSource.SupportsContiguousGet<ATTR>, Releasable, SafeCloseable, AutoCloseable

public abstract class ColumnChunkPageStore<ATTR extends Any>
extends Object
implements PageStore<ATTR,ATTR,ChunkPage<ATTR>>, Page<ATTR>, SafeCloseable, Releasable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ColumnChunkPageStore.CreatorResult<ATTR extends Any>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.ChunkSource

ChunkSource.FillContext, ChunkSource.GetContext

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource

DefaultChunkSource.SupportsContiguousGet<ATTR extends Any>, DefaultChunkSource.WithPrev<ATTR extends Any>

Nested classes/interfaces inherited from interface io.deephaven.engine.page.Page

Page.WithDefaults<ATTR extends Any>, Page.WithDefaultsForRepeatingValues<ATTR extends Any>

Field Summary

Fields inherited from interface io.deephaven.engine.table.ChunkSource

DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

Method Summary

Modifier and Type	Method	Description
void	close()
static <ATTR extends Any> ColumnChunkPageStore.CreatorResult<ATTR>	create(@NotNull PageCache<ATTR> pageCache, @NotNull ColumnChunkReader columnChunkReader, long mask, @NotNull ToPage<ATTR,?> toPage, @NotNull ColumnDefinition<?> columnDefinition)
long	firstRowOffset()
@NotNull ChunkType	getChunkType()	Get the most suitable ChunkType for use with this ChunkSource.
static boolean	hasCorrectVectorOffsetIndexes(@NotNull String version)	Check if the version is greater than or equal to 0.31.0, or it doesn't follow the versioning schema X.Y.Z
long	mask()	This mask is applied to RowSequences which are passed into DefaultChunkSource.getChunk(io.deephaven.engine.table.ChunkSource.GetContext, io.deephaven.engine.rowset.RowSequence), ChunkSource.fillChunk(io.deephaven.engine.table.ChunkSource.FillContext, io.deephaven.chunk.WritableChunk<? super ATTR>, io.deephaven.engine.rowset.RowSequence), and PagingChunkSource.fillChunkAppend(FillContext, WritableChunk, RowSequence.Iterator) .
long	numRows()
boolean	usesDictionaryOnEveryPage()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource

getChunkByFilling, makeGetContext

Methods inherited from interface io.deephaven.engine.table.FillContextMaker

makeFillContext

Methods inherited from interface io.deephaven.engine.table.GetContextMaker

makeGetContext

Methods inherited from interface io.deephaven.engine.page.Page

advanceToNextPage, advanceToNextPage, advanceToNextPageAndGetPositionDistance, firstRow, getRowOffset

Methods inherited from interface io.deephaven.engine.page.PageStore

doFillChunkAppend, fillChunk, fillChunkAppend, getChunk, getChunk, getPageContaining

Methods inherited from interface io.deephaven.engine.page.PagingChunkSource

makeFillContext, maxRow

Methods inherited from interface io.deephaven.engine.table.Releasable

releaseCachedResources

Method Details

hasCorrectVectorOffsetIndexes

@VisibleForTesting
public static boolean hasCorrectVectorOffsetIndexes(@NotNull
 @NotNull String version)

Check if the version is greater than or equal to 0.31.0, or it doesn't follow the versioning schema X.Y.Z

create

public static <ATTR extends Any>
ColumnChunkPageStore.CreatorResult<ATTR> create(@NotNull
 @NotNull PageCache<ATTR> pageCache,
 @NotNull
 @NotNull ColumnChunkReader columnChunkReader,
 long mask,
 @NotNull
 @NotNull ToPage<ATTR,?> toPage,
 @NotNull
 @NotNull ColumnDefinition<?> columnDefinition)
                                         throws IOException

Throws:

IOException

mask

public long mask()

Description copied from interface: PagingChunkSource

This mask is applied to RowSequences which are passed into DefaultChunkSource.getChunk(io.deephaven.engine.table.ChunkSource.GetContext, io.deephaven.engine.rowset.RowSequence), ChunkSource.fillChunk(io.deephaven.engine.table.ChunkSource.FillContext, io.deephaven.chunk.WritableChunk<? super ATTR>, io.deephaven.engine.rowset.RowSequence), and PagingChunkSource.fillChunkAppend(FillContext, WritableChunk, RowSequence.Iterator) . This allows PagingChunkSources to be cached and reused even if they are properly relocated in key space.

Specified by:

mask in interface PagingChunkSource<ATTR extends Any>

Returns:

The mask for this PagingChunkSource, which must be a bitmask representing some number of lower order bits of a long.

firstRowOffset

public long firstRowOffset()

Specified by:

firstRowOffset in interface Page<ATTR extends Any>

Returns:

the first row of this page, after applying the PagingChunkSource.mask(), which refers to the first row of this page.

numRows

public long numRows()

Returns:

The number of rows in this ColumnChunk

getChunkType

@NotNull
public @NotNull ChunkType getChunkType()

Description copied from interface: ChunkSource

Get the most suitable ChunkType for use with this ChunkSource.

Specified by:

getChunkType in interface ChunkSource<ATTR extends Any>

Returns:

The ChunkType

usesDictionaryOnEveryPage

public boolean usesDictionaryOnEveryPage()

See Also:

• ColumnChunkReader.usesDictionaryOnEveryPage()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable