Package io.deephaven.integrations.python

Class PythonMergedListenerAdapter

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.integrations.python.PythonMergedListenerAdapter

All Implemented Interfaces:

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

@ScriptApi
public class PythonMergedListenerAdapter
extends MergedListener

A Deephaven merged listener which fires when any of its bound listener recorders has updates and all of its dependencies have been satisfied. The listener then invokes the Python listener object. The Python listener object must be a Python MergedListener instance that provides a "_process" method implementation with no argument.

See Also:

• Serialized Form

Field Summary

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

entry, result

Method Summary

Modifier and Type	Method	Description
static PythonMergedListenerAdapter	create(@NotNull ListenerRecorder[] recorders, @Nullable NotificationQueue.Dependency[] dependencies, @Nullable String listenerDescription, @NotNull org.jpy.PyObject pyListener, @NotNull org.jpy.PyObject pyOnFailureCallback)
ArrayList<TableUpdate>	currentRowsAsUpdates()
protected void	process()
protected void	propagateErrorDownstream(boolean fromProcess, @NotNull Throwable error, @Nullable TableListener.Entry entry)

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

accumulatePeformanceEntry, append, canExecute, destroy, getRecorders, getUpdateGraph, handleUncaughtException, isFailed, notifyChanges, notifyOnUpstreamError, propagateError, 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

Method Details

create

public static PythonMergedListenerAdapter create(@NotNull
 @NotNull ListenerRecorder[] recorders,
 @Nullable
 @Nullable NotificationQueue.Dependency[] dependencies,
 @Nullable
 @Nullable String listenerDescription,
 @NotNull
 @NotNull org.jpy.PyObject pyListener,
 @NotNull
 @NotNull org.jpy.PyObject pyOnFailureCallback)

currentRowsAsUpdates

public ArrayList<TableUpdate> currentRowsAsUpdates()

process

protected void process()

Specified by:

process in class MergedListener

propagateErrorDownstream

protected void propagateErrorDownstream(boolean fromProcess,
 @NotNull
 @NotNull Throwable error,
 @Nullable TableListener.Entry entry)

Overrides:

propagateErrorDownstream in class MergedListener