Package com.illumon.iris.db.v2.locations.local

Class ReadOnlyParquetTableLocation

java.lang.Object

com.illumon.iris.db.v2.locations.SubscriptionAggregator<TableLocation.Listener>

com.illumon.iris.db.v2.locations.AbstractTableLocation<TableKey,com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

com.illumon.iris.db.v2.locations.local.ReadOnlyParquetTableLocation

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, ParquetFormatTableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>, TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>, TableLocationKey, TableLocationState, NamedImplementation

public class ReadOnlyParquetTableLocation
extends AbstractTableLocation<TableKey,com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>
implements ParquetFormatTableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.locations.TableLocation

TableLocation.Format, TableLocation.Listener

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.locations.TableLocationKey

TableLocationKey.ComparatorImpl, TableLocationKey.KeyedObjectKeyImpl<VALUE_TYPE>, TableLocationKey.SelfKeyedObjectKeyImpl<VALUE_TYPE extends TableLocationKey>

Field Summary

Fields inherited from class com.illumon.iris.db.v2.locations.SubscriptionAggregator

subscriptions

Fields inherited from interface com.illumon.iris.db.v2.locations.TableLocationKey

COMPARATOR, NULL_PARTITION

Fields inherited from interface com.illumon.iris.db.v2.locations.TableLocationState

NULL_SIZE, NULL_TIME, REMOVE_SIZE

Constructor Summary

Constructors

Constructor	Description
ReadOnlyParquetTableLocation(TableKey tableKey, TableLocationKey tableLocationKey, File parquetFile, io.deephaven.parquet.base.ParquetFileReader fileReader, ParquetInstructions instructions)

Method Summary

Modifier and Type	Method	Description
io.deephaven.parquet.base.util.SeekableChannelsProvider	getChannelProvider()	Get the channel provider for reading from the parquet file.
Map<String,ColumnTypeInfo>	getColumnTypes()
int	getColumnVersion()	Get the column version for this location.
Table	getDataIndex(com.illumon.dataobjects.ColumnDefinition<?>... columns)	Get the data index table for the specified set of columns.
Map<String,GroupingColumnInfo>	getGroupingColumns()	Retrieve the GroupingColumnInfo for all available grouping columns.
File	getParquetFile()	Get the full path to the Parquet file for this location.
List<SortPair>	getSortedColumns()	Get an ordered list of columns this location is sorted by.
boolean	hasDataIndexFor(com.illumon.dataobjects.ColumnDefinition<?>... columns)	Check if this location has a data index for the specified columns.
protected com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>	makeColumnLocation(String name)
void	refresh()	Initialize or refresh state information.

Methods inherited from class com.illumon.iris.db.v2.locations.AbstractTableLocation

clearColumnLocations, deliverInitialSnapshot, getColumnLocation, getColumnPartition, getInternalPartition, getLastModifiedTimeMillis, getSize, getStateLock, getTableKey, getVisit, handleUpdate, handleUpdate, toString, visit

Methods inherited from class com.illumon.iris.db.v2.locations.SubscriptionAggregator

activateUnderlyingDataSource, activationFailed, activationSuccessful, checkHasSubscribers, deactivateUnderlyingDataSource, matchSubscriptionToken, postActivationHook, subscribe, supportsSubscriptions, unsubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.util.type.NamedImplementation

getImplementationName

Methods inherited from interface com.illumon.iris.db.v2.locations.ParquetFormatTableLocation

getFormat

Methods inherited from interface com.illumon.iris.db.v2.locations.TableLocation

append, getColumnLocation, getTableKey, getVisit, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe, visit

Methods inherited from interface com.illumon.iris.db.v2.locations.TableLocationKey

getColumnPartition, getInternalPartition, writeTo

Methods inherited from interface com.illumon.iris.db.v2.locations.TableLocationState

copyStateValuesTo, getLastModifiedTimeMillis, getSize, getSizeStr, getStateLock, writeStateValuesTo

Constructor Details

ReadOnlyParquetTableLocation

public ReadOnlyParquetTableLocation(@NotNull TableKey tableKey, @NotNull TableLocationKey tableLocationKey, @NotNull File parquetFile, @NotNull io.deephaven.parquet.base.ParquetFileReader fileReader, @NotNull ParquetInstructions instructions)

Method Details

getParquetFile

@NotNull public File getParquetFile()

Description copied from interface: ParquetFormatTableLocation

Get the full path to the Parquet file for this location.

Specified by:

getParquetFile in interface ParquetFormatTableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Returns:

the parquet file

refresh

public void refresh()

Description copied from interface: TableLocation

Initialize or refresh state information.

Specified by:

refresh in interface TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

getGroupingColumns

public Map<String,GroupingColumnInfo> getGroupingColumns()

Description copied from interface: ParquetFormatTableLocation

Retrieve the GroupingColumnInfo for all available grouping columns.

Specified by:

getGroupingColumns in interface ParquetFormatTableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Returns:

a map of column name to GroupingColumnInfo

getChannelProvider

public io.deephaven.parquet.base.util.SeekableChannelsProvider getChannelProvider()

Description copied from interface: ParquetFormatTableLocation

Get the channel provider for reading from the parquet file.

Specified by:

getChannelProvider in interface ParquetFormatTableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Returns:

a SeekableChannelsProvider to read from the file

getSortedColumns

@NotNull public List<SortPair> getSortedColumns()

Description copied from interface: TableLocation

Get an ordered list of columns this location is sorted by.

Specified by:

getSortedColumns in interface TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Returns:

a non-null ordered list of SortPairs

makeColumnLocation

@NotNull protected com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values> makeColumnLocation(@NotNull String name)

Specified by:

makeColumnLocation in class AbstractTableLocation<TableKey,com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

getColumnTypes

public Map<String,ColumnTypeInfo> getColumnTypes()

hasDataIndexFor

public boolean hasDataIndexFor(@NotNull com.illumon.dataobjects.ColumnDefinition<?>... columns)

Description copied from interface: TableLocation

Check if this location has a data index for the specified columns.

Specified by:

hasDataIndexFor in interface TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Parameters:

columns - the set of columns to check for.

Returns:

true if the table has a Data Index for the specified columns

getDataIndex

@Nullable public Table getDataIndex(@NotNull com.illumon.dataobjects.ColumnDefinition<?>... columns)

Description copied from interface: TableLocation

Get the data index table for the specified set of columns. Note that the order of columns does not matter here.

Specified by:

getDataIndex in interface TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Parameters:

columns - the key columns for the index

Returns:

the index table or null if one does not exist.

getColumnVersion

public int getColumnVersion()

Description copied from interface: TableLocation

Get the column version for this location.

Specified by:

getColumnVersion in interface TableLocation<com.illumon.iris.db.v2.locations.local.ParquetColumnLocation<Attributes.Values>>

Returns:

the column version