Package io.deephaven.enterprise.locations.local

Class SnapshotBackedTableLocation<LOCATION_TYPE extends AbstractTableLocation>

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.enterprise.locations.local.SnapshotBackedTableLocation<LOCATION_TYPE>

Type Parameters:

LOCATION_TYPE -

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, TableLocation, TableLocationState, NamedImplementation

public class SnapshotBackedTableLocation<LOCATION_TYPE extends AbstractTableLocation>
extends ReferenceCountedLivenessNode
implements TableLocation

A TableLocation backed by a TableLocationMetadataIndex.TableLocationSnapshot that does not refresh and tries to avoid creating the actual location until it is truly needed.

Nested Class Summary

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

TableLocation.Listener

Field Summary

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

NULL_SIZE, NULL_TIME

Constructor Summary

Constructors

Constructor	Description
SnapshotBackedTableLocation(@NotNull TableKey tableKey, @NotNull TableLocationKey tableLocationKey, io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.TableLocationMetadataIndex.LocationSnapshot snapshot, @NotNull Supplier<LOCATION_TYPE> locationFactory)

Method Summary

Modifier and Type	Method	Description
@NotNull ColumnLocation	getColumnLocation(@NotNull CharSequence name)
@Nullable BasicDataIndex	getDataIndex(@NotNull String... columns)
@NotNull List<String[]>	getDataIndexColumns()
@NotNull ImmutableTableLocationKey	getKey()
long	getLastModifiedTimeMillis()
RowSet	getRowSet()
long	getSize()
@NotNull List<SortColumn>	getSortedColumns()
@NotNull Object	getStateLock()
@NotNull ImmutableTableKey	getTableKey()
boolean	hasDataIndex(@NotNull String... columns)
void	refresh()
void	subscribe(@NotNull TableLocation.Listener listener)
boolean	supportsSubscriptions()
void	unsubscribe(@NotNull TableLocation.Listener listener)

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

destroy, dropReference, tryRetainReference

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

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

manage, unmanage, unmanage

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

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

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

getImplementationName

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

append, toGenericString, toStringDetailed, toStringHelper

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

copyStateValuesTo

Constructor Details

SnapshotBackedTableLocation

public SnapshotBackedTableLocation(@NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey tableLocationKey,
 @NotNull
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.TableLocationMetadataIndex.LocationSnapshot snapshot,
 @NotNull
 @NotNull Supplier<LOCATION_TYPE> locationFactory)

Parameters:

tableKey - Table key for the table this location belongs to

tableLocationKey - Table location key that identifies this location

Method Details

getTableKey

@NotNull
public @NotNull ImmutableTableKey getTableKey()

Specified by:

getTableKey in interface TableLocation

getKey

@NotNull
public @NotNull ImmutableTableLocationKey getKey()

Specified by:

getKey in interface TableLocation

supportsSubscriptions

public boolean supportsSubscriptions()

Specified by:

supportsSubscriptions in interface TableLocation

subscribe

public void subscribe(@NotNull
 @NotNull TableLocation.Listener listener)

Specified by:

subscribe in interface TableLocation

unsubscribe

public void unsubscribe(@NotNull
 @NotNull TableLocation.Listener listener)

Specified by:

unsubscribe in interface TableLocation

refresh

public void refresh()

Specified by:

refresh in interface TableLocation

getSortedColumns

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

Specified by:

getSortedColumns in interface TableLocation

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

getDataIndex

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

Specified by:

getDataIndex in interface TableLocation

getColumnLocation

@NotNull
public @NotNull ColumnLocation getColumnLocation(@NotNull
 @NotNull CharSequence name)

Specified by:

getColumnLocation in interface TableLocation

getStateLock

@NotNull
public @NotNull Object getStateLock()

Specified by:

getStateLock in interface TableLocationState

getRowSet

public RowSet getRowSet()

Specified by:

getRowSet in interface TableLocationState

getSize

public long getSize()

Specified by:

getSize in interface TableLocationState

getLastModifiedTimeMillis

public long getLastModifiedTimeMillis()

Specified by:

getLastModifiedTimeMillis in interface TableLocationState