Package io.deephaven.parquet.table.location

Class ParquetTableLocation

java.lang.Object

io.deephaven.engine.table.impl.locations.impl.SubscriptionAggregator<TableLocation.Listener>

io.deephaven.engine.table.impl.locations.impl.AbstractTableLocation

io.deephaven.parquet.table.location.ParquetTableLocation

All Implemented Interfaces:

LogOutputAppendable, TableLocation, TableLocationState, NamedImplementation

public class ParquetTableLocation
extends AbstractTableLocation

Nested Class Summary

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

TableLocation.Listener

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.locations.impl.SubscriptionAggregator

subscriptions

Fields inherited from interface io.deephaven.engine.table.impl.locations.TableLocationState

NULL_SIZE, NULL_TIME

Constructor Summary

Constructors

Constructor	Description
ParquetTableLocation(@NotNull TableKey tableKey, @NotNull ParquetTableLocationKey tableLocationKey, @NotNull ParquetInstructions readInstructions)

Method Summary

Modifier and Type	Method	Description
Map<String,ColumnTypeInfo>	getColumnTypes()
Map<String,GroupingColumnInfo>	getGroupingColumns()
String	getImplementationName()	Get a name for the implementing class.
protected @NotNull io.deephaven.parquet.table.location.ParquetColumnLocation<Values>	makeColumnLocation(@NotNull String columnName)
void	refresh()	Initialize or run state information.

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.AbstractTableLocation

clearColumnLocations, deliverInitialSnapshot, getColumnLocation, getKey, getLastModifiedTimeMillis, getRowSet, getSize, getStateLock, getTableKey, handleUpdate, handleUpdate, toString

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.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 io.deephaven.engine.table.impl.locations.TableLocation

append, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe

Methods inherited from interface io.deephaven.engine.table.impl.locations.TableLocationState

copyStateValuesTo

Constructor Details

ParquetTableLocation

public ParquetTableLocation(@NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull ParquetTableLocationKey tableLocationKey,
 @NotNull
 @NotNull ParquetInstructions readInstructions)

Method Details

getImplementationName

public String getImplementationName()

Description copied from interface: NamedImplementation

Get a name for the implementing class. Useful for abstract classes that implement LogOutputAppendable or override toString.

The default implementation is correct, but not suitable for high-frequency usage.

Returns:

A name for the implementing class

refresh

public void refresh()

Description copied from interface: TableLocation

Initialize or run state information.

getGroupingColumns

public Map<String,GroupingColumnInfo> getGroupingColumns()

getColumnTypes

public Map<String,ColumnTypeInfo> getColumnTypes()

makeColumnLocation

@NotNull
protected @NotNull io.deephaven.parquet.table.location.ParquetColumnLocation<Values> makeColumnLocation(@NotNull
 @NotNull String columnName)

Specified by:

makeColumnLocation in class AbstractTableLocation