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, PushdownFilterMatcher, RegionedPushdownFilterMatcher, 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
long	estimatePushdownAction(RegionedPushdownAction action, WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext filterContext, RegionedPushdownAction.EstimateContext estimateContext)
void	estimatePushdownFilterCost(WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, JobScheduler jobScheduler, LongConsumer onComplete, Consumer<Exception> onError)
@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	hasCachedDataIndex(@NotNull String... columns)
boolean	hasDataIndex(@NotNull String... columns)
RegionedPushdownAction.ActionContext	makeActionContext(WhereFilter filter, PushdownFilterContext context)
RegionedPushdownAction.EstimateContext	makeEstimateContext(WhereFilter filter, PushdownFilterContext context)
PushdownFilterContext	makePushdownFilterContext(WhereFilter filter, List<ColumnSource<?>> filterSources)
PushdownResult	performPushdownAction(RegionedPushdownAction action, WhereFilter filter, RowSet selection, PushdownResult input, boolean usePrev, PushdownFilterContext filterContext, RegionedPushdownAction.ActionContext actionContext)
void	pushdownFilter(WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, long costCeiling, JobScheduler jobScheduler, Consumer<PushdownResult> onComplete, Consumer<Exception> onError)
void	refresh()
void	subscribe(@NotNull TableLocation.Listener listener)
List<RegionedPushdownAction>	supportedActions()
boolean	supportsSubscriptions()
void	unsubscribe(@NotNull TableLocation.Listener listener)

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

ensureCleanupOnGC, findAnyManagedReferent, forEachManagedReference, 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.PushdownFilterMatcher

estimatePushdownFilterCost, makePushdownFilterContext, pushdownFilter

Methods inherited from interface io.deephaven.engine.table.impl.sources.regioned.RegionedPushdownFilterMatcher

estimatePushdownAction, makeActionContext, makeEstimateContext, performPushdownAction, supportedActions

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

append, getColumnLocation, getDataIndex, getDataIndexColumns, getKey, getSortedColumns, getTableKey, hasCachedDataIndex, hasDataIndex, refresh, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe

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

copyStateValuesTo, getLastModifiedTimeMillis, getStateLock

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

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

hasCachedDataIndex

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

Specified by:

hasCachedDataIndex in interface TableLocation

supportedActions

public List<RegionedPushdownAction> supportedActions()

Specified by:

supportedActions in interface RegionedPushdownFilterMatcher

makePushdownFilterContext

public PushdownFilterContext makePushdownFilterContext(WhereFilter filter,
 List<ColumnSource<?>> filterSources)

Specified by:

makePushdownFilterContext in interface PushdownFilterMatcher

estimatePushdownFilterCost

public void estimatePushdownFilterCost(WhereFilter filter,
 RowSet selection,
 boolean usePrev,
 PushdownFilterContext context,
 JobScheduler jobScheduler,
 LongConsumer onComplete,
 Consumer<Exception> onError)

Specified by:

estimatePushdownFilterCost in interface PushdownFilterMatcher

pushdownFilter

public void pushdownFilter(WhereFilter filter,
 RowSet selection,
 boolean usePrev,
 PushdownFilterContext context,
 long costCeiling,
 JobScheduler jobScheduler,
 Consumer<PushdownResult> onComplete,
 Consumer<Exception> onError)

Specified by:

pushdownFilter in interface PushdownFilterMatcher

makeEstimateContext

public RegionedPushdownAction.EstimateContext makeEstimateContext(WhereFilter filter,
 PushdownFilterContext context)

Specified by:

makeEstimateContext in interface RegionedPushdownFilterMatcher

estimatePushdownAction

public long estimatePushdownAction(RegionedPushdownAction action,
 WhereFilter filter,
 RowSet selection,
 boolean usePrev,
 PushdownFilterContext filterContext,
 RegionedPushdownAction.EstimateContext estimateContext)

Specified by:

estimatePushdownAction in interface RegionedPushdownFilterMatcher

makeActionContext

public RegionedPushdownAction.ActionContext makeActionContext(WhereFilter filter,
 PushdownFilterContext context)

Specified by:

makeActionContext in interface RegionedPushdownFilterMatcher

performPushdownAction

public PushdownResult performPushdownAction(RegionedPushdownAction action,
 WhereFilter filter,
 RowSet selection,
 PushdownResult input,
 boolean usePrev,
 PushdownFilterContext filterContext,
 RegionedPushdownAction.ActionContext actionContext)

Specified by:

performPushdownAction in interface RegionedPushdownFilterMatcher

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