Package com.illumon.iris.db.v2

Class MergedListener

java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

com.illumon.iris.db.util.liveness.LivenessArtifact

com.illumon.iris.db.v2.MergedListener

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, NotificationQueue.Dependency, LivenessManager, LivenessNode, LivenessReferent, Serializable

Direct Known Subclasses:

BucketedChunkedAjMergedListener, SnapshotIncrementalListener, ZeroKeyChunkedAjMergedListener

public abstract class MergedListener
extends LivenessArtifact
implements NotificationQueue.Dependency

A merged listener has a collection of ListenerRecorders. Each one must complete before the merged listener fires its sole notification for the cycle. You must use a MergedListener if your result table has multiple sources, otherwise it is possible for a table to produce notifications more than once in a cycle; which is an error.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	failed
protected QueryTable	result

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MergedListener(com.fishlib.io.logger.Logger log, Collection<? extends ListenerRecorder> recorders, Collection<NotificationQueue.Dependency> dependencies, String listenerDescription, QueryTable result)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
protected boolean	canExecute(long step)
void	notifyChanges()
protected void	notifyClientOnError(Throwable originalException)
protected void	notifyOnError(Throwable updateException)	Notify that an error has occurred.
protected void	notifyOnError(Throwable updateException, QueryTable downstream)
protected abstract void	process()
boolean	satisfied(long step)	Is this ancestor satisfied? Note that this method must be safe to call on any thread.
protected boolean	systemicResult()

Methods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact

manageWithCurrentScope, unmanage, unmanage

Methods inherited from class com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

destroy, dropReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryRetainReference

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

decrementReferenceCount, 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 com.illumon.iris.db.util.liveness.LivenessManager

manage

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent

getReferentDescription, retainReference

Field Details

result

protected QueryTable result

failed

protected boolean failed

Constructor Details

MergedListener

protected MergedListener(com.fishlib.io.logger.Logger log,
 Collection<? extends ListenerRecorder> recorders,
 Collection<NotificationQueue.Dependency> dependencies,
 String listenerDescription,
 QueryTable result)

Method Details

notifyChanges

public void notifyChanges()

notifyOnError

protected void notifyOnError(Throwable updateException)

Notify that an error has occurred. Note: If this method is overridden, the child class is responsible for updating the failed member when failure processing is complete.

Parameters:

updateException - the exception causing the failure.

systemicResult

protected boolean systemicResult()

notifyOnError

protected void notifyOnError(Throwable updateException,
 QueryTable downstream)

notifyClientOnError

protected void notifyClientOnError(Throwable originalException)

process

protected abstract void process()

append

public com.fishlib.base.log.LogOutput append(@NotNull
 com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable

Overrides:

append in class ReferenceCounted

canExecute

protected boolean canExecute(long step)

satisfied

public boolean satisfied(long step)

Description copied from interface: NotificationQueue.Dependency

Is this ancestor satisfied? Note that this method must be safe to call on any thread.

Specified by:

satisfied in interface NotificationQueue.Dependency

Parameters:

step - The step for which we are testing satisfaction

Returns:

Whether the dependency is satisfied on step (and will not fire subsequent notifications)