Package io.deephaven.engine.table.impl.snapshot

Class SnapshotInternalListener

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.engine.liveness.LivenessArtifact

io.deephaven.engine.table.impl.InstrumentedTableListenerBase

io.deephaven.engine.table.impl.InstrumentedTableUpdateListener

io.deephaven.engine.table.impl.BaseTable.ListenerImpl

io.deephaven.engine.table.impl.snapshot.SnapshotInternalListener

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, TableListener, TableUpdateListener, NotificationQueue.Dependency, Serializable

public class SnapshotInternalListener
extends BaseTable.ListenerImpl

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.InstrumentedTableUpdateListener

InstrumentedTableUpdateListener.Notification

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.InstrumentedTableListenerBase

InstrumentedTableListenerBase.ErrorNotification, InstrumentedTableListenerBase.NotificationBase

Nested classes/interfaces inherited from interface io.deephaven.engine.table.TableListener

TableListener.Entry

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.InstrumentedTableListenerBase

failed

Constructor Summary

Constructors

Constructor	Description
SnapshotInternalListener(QueryTable triggerTable, boolean lazySnapshot, Table snapshotTable, QueryTable result, Map<String,SingleValueColumnSource<?>> resultTriggerColumns, Map<String,WritableColumnSource<?>> resultBaseColumns, TrackingWritableRowSet resultRowSet)

Method Summary

Modifier and Type	Method	Description
boolean	canExecute(long step)
void	doSnapshot(boolean notifyListeners, boolean usePrev)
void	onUpdate(TableUpdate upstream)	Process notification of table changes.

Methods inherited from class io.deephaven.engine.table.impl.BaseTable.ListenerImpl

destroy, getDependent, getParent, onFailureInternal

Methods inherited from class io.deephaven.engine.table.impl.InstrumentedTableUpdateListener

getNotification

Methods inherited from class io.deephaven.engine.table.impl.InstrumentedTableListenerBase

append, getEntry, getErrorNotification, getUpdateGraph, onFailure, onFailureInternalWithDependent, satisfied, setVerboseLogging, toString

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

manageWithCurrentScope

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

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

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

dropReference, tryRetainReference

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

decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, 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, tryManage

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

tryUnmanage, tryUnmanage, unmanage, unmanage

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

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph

Methods inherited from interface io.deephaven.engine.table.TableListener

getErrorNotification, onFailure

Constructor Details

SnapshotInternalListener

public SnapshotInternalListener(QueryTable triggerTable,
 boolean lazySnapshot,
 Table snapshotTable,
 QueryTable result,
 Map<String,SingleValueColumnSource<?>> resultTriggerColumns,
 Map<String,WritableColumnSource<?>> resultBaseColumns,
 TrackingWritableRowSet resultRowSet)

Method Details

onUpdate

public void onUpdate(TableUpdate upstream)

Description copied from interface: TableUpdateListener

Process notification of table changes.

The TableUpdateListener onUpdate call executes within the UpdateGraph refresh loop. Any tables used within the listener's onUpdate call must have already been refreshed. Using the typical pattern of a Listener that is listening to a single table, with Table.addUpdateListener(TableUpdateListener), this is trivially true.

When the listener must reference more than just one parent, the tables (or other objects) it references, must be made a NotificationQueue.Dependency of the listener. For listeners that reference multiple ticking tables, a common pattern is to use a MergedListener and collection of ListenerRecorders.

Specified by:

onUpdate in interface TableUpdateListener

Overrides:

onUpdate in class BaseTable.ListenerImpl

Parameters:

upstream - The set of upstream table updates.

doSnapshot

public void doSnapshot(boolean notifyListeners,
 boolean usePrev)

canExecute

public boolean canExecute(long step)

Overrides:

canExecute in class BaseTable.ListenerImpl