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

Class SnapshotIncrementalListener

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.MergedListener

io.deephaven.engine.table.impl.snapshot.SnapshotIncrementalListener

All Implemented Interfaces:

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

public class SnapshotIncrementalListener
extends MergedListener

See Also:

• Serialized Form

Field Summary

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

entry, result

Constructor Summary

Constructors

Constructor	Description
SnapshotIncrementalListener(QueryTable triggerTable, QueryTable resultTable, Map<String,WritableColumnSource<?>> resultColumns, ListenerRecorder baseListener, ListenerRecorder triggerListener, QueryTable baseTable, Map<String,? extends ColumnSource<?>> triggerColumns)

Method Summary

Modifier and Type	Method	Description
static void	copyRowsToResult(RowSet rowsToCopy, QueryTable triggerTable, Map<String,ChunkSource.WithPrev<? extends Values>> snapshotDataColumns, Map<String,? extends ColumnSource<?>> triggerColumns, Map<String,WritableColumnSource<?>> resultColumns)
void	doFirstSnapshot(boolean initial)
void	doSnapshot()
protected void	process()

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

accumulatePeformanceEntry, append, canExecute, destroy, getRecorders, getUpdateGraph, handleUncaughtException, isFailed, notifyChanges, notifyOnUpstreamError, propagateError, propagateErrorDownstream, satisfied, scheduleDelayedErrorNotifier, systemicResult

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, 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

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

unmanage, unmanage

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

dropReference, getReferentDescription, retainReference, tryRetainReference

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

getUpdateGraph

Constructor Details

SnapshotIncrementalListener

public SnapshotIncrementalListener(QueryTable triggerTable,
 QueryTable resultTable,
 Map<String,WritableColumnSource<?>> resultColumns,
 ListenerRecorder baseListener,
 ListenerRecorder triggerListener,
 QueryTable baseTable,
 Map<String,? extends ColumnSource<?>> triggerColumns)

Method Details

process

protected void process()

Specified by:

process in class MergedListener

doFirstSnapshot

public void doFirstSnapshot(boolean initial)

doSnapshot

public void doSnapshot()

copyRowsToResult

public static void copyRowsToResult(RowSet rowsToCopy,
 QueryTable triggerTable,
 Map<String,ChunkSource.WithPrev<? extends Values>> snapshotDataColumns,
 Map<String,? extends ColumnSource<?>> triggerColumns,
 Map<String,WritableColumnSource<?>> resultColumns)