Package io.deephaven.enterprise.locations.local.deephaven

Class OnDiskDeephavenTableLocation

java.lang.Object

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

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

io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation

All Implemented Interfaces:

LogOutputAppendable, DelegatingLivenessReferent, LivenessReferent, ColumnToCodecMappings, TableLocation, TableLocationState, DeephavenFormatTableLocation, io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutputAppendable, NamedImplementation

public class OnDiskDeephavenTableLocation
extends AbstractTableLocation
implements DeephavenFormatTableLocation, ColumnToCodecMappings

A TableLocation for reading Deephaven format tables from a local filesystem.

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.ColumnToCodecMappings

EMPTY

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

NULL_SIZE, NULL_TIME

Constructor Summary

Constructors

Constructor	Description
OnDiskDeephavenTableLocation(@NotNull EnterpriseTableKey tableKey, @NotNull EnterpriseTableLocationKey tableLocationKey, @Nullable io.deephaven.shadow.enterprise.com.illumon.iris.db.schema.Schema schema, @NotNull File directory, boolean supportsSubscriptions, @Nullable TableDataRefreshService refreshService)

Method Summary

Modifier and Type	Method	Description
protected void	activateUnderlyingDataSource()
protected void	deactivateUnderlyingDataSource()
String	getCodecArgs(@NotNull String columnName)
String	getCodecName(@NotNull String columnName)
@NotNull List<String[]>	getDataIndexColumns()
@Nullable io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition	getDheDefinition()	Get the Enterprise TableDefinition for this location.
@NotNull List<SortColumn>	getSortedColumns()
boolean	hasDataIndex(@NotNull String... columns)
@Nullable BasicDataIndex	loadDataIndex(@NotNull String... columns)
static @Nullable Table	loadDataIndexTable(@NotNull File directory, @NotNull String[] columns)	Load a Data Index from an Enterprise on disk index table.
protected @NotNull OnDiskDeephavenColumnLocation	makeColumnLocation(@NotNull String name)
protected <T> boolean	matchSubscriptionToken(T token)
void	refresh()
void	setSnapshot(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.TableLocationMetadataIndex.LocationSnapshot snapshot)	Set the location snapshot data from the metadata index.

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

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

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

activationFailed, activationSuccessful, checkHasSubscribers, 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.enterprise.locations.DeephavenFormatTableLocation

append

Methods inherited from interface io.deephaven.engine.liveness.DelegatingLivenessReferent

dropReference, getWeakReference, tryRetainReference

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

getReferentDescription, retainReference

Methods inherited from interface io.deephaven.util.type.NamedImplementation

getImplementationName

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

append, getColumnLocation, getDataIndex, getKey, getTableKey, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe

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

copyStateValuesTo, getLastModifiedTimeMillis, getRowSet, getSize, getStateLock

Constructor Details

OnDiskDeephavenTableLocation

public OnDiskDeephavenTableLocation(@NotNull
 @NotNull EnterpriseTableKey tableKey,
 @NotNull
 @NotNull EnterpriseTableLocationKey tableLocationKey,
 @Nullable
 @Nullable io.deephaven.shadow.enterprise.com.illumon.iris.db.schema.Schema schema,
 @NotNull
 @NotNull File directory,
 boolean supportsSubscriptions,
 @Nullable
 @Nullable TableDataRefreshService refreshService)

Method Details

refresh

public void refresh()

Specified by:

refresh in interface TableLocation

getSortedColumns

@NotNull
public @NotNull List<SortColumn> getSortedColumns()

Specified by:

getSortedColumns in interface TableLocation

activateUnderlyingDataSource

protected void activateUnderlyingDataSource()

Overrides:

activateUnderlyingDataSource in class SubscriptionAggregator<TableLocation.Listener>

deactivateUnderlyingDataSource

protected void deactivateUnderlyingDataSource()

Overrides:

deactivateUnderlyingDataSource in class SubscriptionAggregator<TableLocation.Listener>

matchSubscriptionToken

protected <T> boolean matchSubscriptionToken(T token)

Overrides:

matchSubscriptionToken in class SubscriptionAggregator<TableLocation.Listener>

makeColumnLocation

@NotNull
protected @NotNull OnDiskDeephavenColumnLocation makeColumnLocation(@NotNull
 @NotNull String name)

Specified by:

makeColumnLocation in class AbstractTableLocation

getDataIndexColumns

@NotNull
public @NotNull List<String[]> getDataIndexColumns()

Specified by:

getDataIndexColumns in interface TableLocation

hasDataIndex

public boolean hasDataIndex(@NotNull
 @NotNull String... columns)

Specified by:

hasDataIndex in interface TableLocation

loadDataIndex

@Nullable
public @Nullable BasicDataIndex loadDataIndex(@NotNull
 @NotNull String... columns)

Specified by:

loadDataIndex in class AbstractTableLocation

loadDataIndexTable

@Nullable
public static @Nullable Table loadDataIndexTable(@NotNull
 @NotNull File directory,
 @NotNull
 @NotNull String[] columns)

Load a Data Index from an Enterprise on disk index table.

Parameters:

directory - the location of the table.

columns - the columns indexed.

Returns:

a Table containing the index, or null if one was not found

getCodecName

public String getCodecName(@NotNull
 @NotNull String columnName)

Specified by:

getCodecName in interface ColumnToCodecMappings

getCodecArgs

public String getCodecArgs(@NotNull
 @NotNull String columnName)

Specified by:

getCodecArgs in interface ColumnToCodecMappings

getDheDefinition

@Nullable
public @Nullable io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition getDheDefinition()

Get the Enterprise TableDefinition for this location.

Returns:

the Enterprise TableDefinition

setSnapshot

public void setSnapshot(@NotNull
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.TableLocationMetadataIndex.LocationSnapshot snapshot)

Set the location snapshot data from the metadata index.

Parameters:

snapshot - the metadata index for this location.