Package io.deephaven.enterprise.locations.local

Class HybridSnapshotBackedTableLocation<REAL_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.HybridSnapshotBackedTableLocation<REAL_LOCATION_TYPE>

Type Parameters:

REAL_LOCATION_TYPE - the type of the real location, which must extend AbstractTableLocation

All Implemented Interfaces:

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

public class HybridSnapshotBackedTableLocation<REAL_LOCATION_TYPE extends AbstractTableLocation>
extends ReferenceCountedLivenessNode
implements TableLocation

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

Subscriptions are not supported.

The distinction between the HybridSnapshotBackedTableLocation and the SnapshotBackedTableLocation is that for the hybrid version we may not have the rowset available from the snapshot. If the rowset is unavailable (null), then must realize the real location to return the rowset. This has the effect of requiring the Parquet file to be read to determine how many row groups there are upon the table .coalesce() operation. When only the size is needed (e.g. to just discover the locations and understand they are non-empty), a snapshot without the row group information is sufficient.

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
HybridSnapshotBackedTableLocation(@NotNull TableKey tableKey, @NotNull TableLocationKey tableLocationKey, io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.TableLocationMetadataIndex.LocationSnapshot snapshot, @NotNull Supplier<REAL_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, getColumnLocation, getDataIndex, getDataIndexColumns, getKey, getSortedColumns, getTableKey, hasDataIndex, refresh, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe

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

copyStateValuesTo, getLastModifiedTimeMillis, getStateLock

Constructor Details

HybridSnapshotBackedTableLocation

public HybridSnapshotBackedTableLocation(@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<REAL_LOCATION_TYPE> locationFactory)

Parameters:

tableKey - Table key for the table this location belongs to

tableLocationKey - Table location key that identifies this location

Method Details

getRowSet

public RowSet getRowSet()

Specified by:

getRowSet in interface TableLocationState

getSize

public long getSize()

Specified by:

getSize in interface TableLocationState

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

getLastModifiedTimeMillis

public long getLastModifiedTimeMillis()

Specified by:

getLastModifiedTimeMillis in interface TableLocationState