Package io.deephaven.engine.table.impl.asofjoin

Class BucketedChunkedAjMergedListener

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.asofjoin.BucketedChunkedAjMergedListener

All Implemented Interfaces:

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

public class BucketedChunkedAjMergedListener
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

BucketedChunkedAjMergedListener(JoinListenerRecorder leftRecorder, JoinListenerRecorder rightRecorder, String listenerDescription, QueryTable result, QueryTable leftTable, QueryTable rightTable, MatchPair[] columnsToMatch, MatchPair stampPair, MatchPair[] columnsToAdd, ColumnSource<?>[] leftSources, ColumnSource<?>[] rightSources, ColumnSource<?> leftStampSource, ColumnSource<?> rightStampSource, AsOfJoinHelper.SsaFactory leftSsaFactory, AsOfJoinHelper.SsaFactory rightSsaFactory, SortingOrder order, boolean disallowExactMatch, SsaSsaStamp ssaSsaStamp, JoinControl control, RightIncrementalHashedAsOfJoinStateManager asOfJoinStateManager, WritableRowRedirection rowRedirection)

Method Summary

Modifier and Type	Method	Description
protected void	destroy()	Attempt to release (destructively when necessary) resources held by this object.
void	process()

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

accumulatePeformanceEntry, append, canExecute, 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

BucketedChunkedAjMergedListener

public BucketedChunkedAjMergedListener(JoinListenerRecorder leftRecorder,
 JoinListenerRecorder rightRecorder,
 String listenerDescription,
 QueryTable result,
 QueryTable leftTable,
 QueryTable rightTable,
 MatchPair[] columnsToMatch,
 MatchPair stampPair,
 MatchPair[] columnsToAdd,
 ColumnSource<?>[] leftSources,
 ColumnSource<?>[] rightSources,
 ColumnSource<?> leftStampSource,
 ColumnSource<?> rightStampSource,
 AsOfJoinHelper.SsaFactory leftSsaFactory,
 AsOfJoinHelper.SsaFactory rightSsaFactory,
 SortingOrder order,
 boolean disallowExactMatch,
 SsaSsaStamp ssaSsaStamp,
 JoinControl control,
 RightIncrementalHashedAsOfJoinStateManager asOfJoinStateManager,
 WritableRowRedirection rowRedirection)

Method Details

process

public void process()

Specified by:

process in class MergedListener

destroy

protected void destroy()

Description copied from class: ReferenceCountedLivenessReferent

Attempt to release (destructively when necessary) resources held by this object. This may render the object unusable for subsequent operations. Implementations should be sure to call super.destroy().

This is intended to only ever be used as a side effect of decreasing the reference count to 0.

Overrides:

destroy in class MergedListener