Package io.deephaven.enterprise.tabledataservice

Class MarkingPollingLocationProvider<TK extends TableKey,TLK extends TableLocationKey>

java.lang.Object

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

io.deephaven.engine.table.impl.locations.impl.AbstractTableLocationProvider

io.deephaven.engine.table.impl.locations.impl.PollingTableLocationProvider<TK,TLK>

io.deephaven.enterprise.tabledataservice.MarkingPollingLocationProvider<TK,TLK>

Type Parameters:

TK -

TLK -

All Implemented Interfaces:

TableLocationProvider, NamedImplementation

public class MarkingPollingLocationProvider<TK extends TableKey,TLK extends TableLocationKey>
extends PollingTableLocationProvider<TK,TLK>

A TableLocationProvider that will perform a mark/sweep of active locations on refresh.

Nested Class Summary

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

TableLocationProvider.Listener

Field Summary

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

subscriptions

Constructor Summary

Constructors

Constructor	Description
MarkingPollingLocationProvider(TK tableKey, @NotNull TableLocationKeyFinder<TLK> locationKeyFinder, @NotNull TableLocationFactory<TK,TLK> locationFactory, @Nullable TableDataRefreshService refreshService)

Method Summary

Modifier and Type	Method	Description
void	refresh()
protected void	visitLocationKey(@NotNull TableLocationKey locationKey)

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

activateUnderlyingDataSource, deactivateUnderlyingDataSource, getImplementationName, makeTableLocation, matchSubscriptionToken

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

deliverInitialSnapshot, doInitialization, ensureInitialized, getKey, getTableLocationIfPresent, getTableLocationKeys, handleTableLocationKey, handleTableLocationKeyRemoved, hasTableLocationKey, isInitialized, removeTableLocationKey, setInitialized, 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.engine.table.impl.locations.TableLocationProvider

getName, getTableLocation, subscribe, supportsSubscriptions, unsubscribe

Constructor Details

MarkingPollingLocationProvider

public MarkingPollingLocationProvider(@NotNull
 TK tableKey,
 @NotNull
 @NotNull TableLocationKeyFinder<TLK> locationKeyFinder,
 @NotNull
 @NotNull TableLocationFactory<TK,TLK> locationFactory,
 @Nullable
 @Nullable TableDataRefreshService refreshService)

Method Details

refresh

@OverridingMethodsMustInvokeSuper
public void refresh()

Specified by:

refresh in interface TableLocationProvider

Overrides:

refresh in class PollingTableLocationProvider<TK extends TableKey,TLK extends TableLocationKey>

visitLocationKey

protected void visitLocationKey(@NotNull
 @NotNull TableLocationKey locationKey)

Overrides:

visitLocationKey in class AbstractTableLocationProvider