public class ReactiveFromNode extends FromNode<ReactiveFromNode.ReactiveFromMemory>
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveFromNode.ReactiveFromMemory |
FromNode.FromMemory
alphaConstraints, betaConstraints, dataProvider, from, nextTupleSinkNode, objectTypeConf, previousTupleSinkNode, resultClass, tupleMemoryEnabled
leftInput, sink
associations, hashcode, id, partitionId, partitionsEnabled
Constructor and Description |
---|
ReactiveFromNode() |
ReactiveFromNode(int id,
DataProvider dataProvider,
LeftTupleSource tupleSource,
AlphaNodeFieldConstraint[] constraints,
BetaConstraints binder,
boolean tupleMemoryEnabled,
BuildContext context,
From from) |
Modifier and Type | Method and Description |
---|---|
ReactiveFromNode.ReactiveFromMemory |
createMemory(RuleBaseConfiguration config,
InternalWorkingMemory wm) |
short |
getType() |
String |
toString() |
addToCreatedHandlesMap, assertLeftTuple, attach, createFactHandle, createLeftTuple, createLeftTuple, createLeftTuple, createLeftTuple, createLeftTuple, createPeer, createRightTuple, doRemove, equals, getAlphaConstraints, getBetaConstraints, getDataProvider, getLeftTupleSource, getNextLeftTupleSinkNode, getObjectTypeNode, getPreviousLeftTupleSinkNode, getResultClass, internalEquals, isLeftTupleMemoryEnabled, modifyLeftTuple, modifyLeftTuple, networkUpdated, readExternal, retractLeftTuple, setLeftTupleMemoryEnabled, setNextLeftTupleSinkNode, setPreviousLeftTupleSinkNode, updateSink, writeExternal
addTupleSink, addTupleSink, addTupleSink, getLeftDeclaredMask, getLeftInferredMask, getLeftInputOtnId, getLeftNegativeMask, getObjectType, getPositionInPath, getSinkPropagator, initDeclaredMask, initInferredMask, initMasks, isInUse, removeTupleSink, setLeftInferredMask, setLeftInputOtnId, setLeftListenedProperties, setLeftTupleSource
addAssociation, addAssociation, getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, getSinks, hashCode, isAssociatedWith, isStreamMode, remove, removeAssociation, setId, setPartitionId, setStreamMode, thisNodeEquals
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getLeftInferredMask, getLeftInputOtnId, setLeftInputOtnId
getPositionInPath, getSinkPropagator
getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, isAssociatedWith, thisNodeEquals
getId
public ReactiveFromNode()
public ReactiveFromNode(int id, DataProvider dataProvider, LeftTupleSource tupleSource, AlphaNodeFieldConstraint[] constraints, BetaConstraints binder, boolean tupleMemoryEnabled, BuildContext context, From from)
public ReactiveFromNode.ReactiveFromMemory createMemory(RuleBaseConfiguration config, InternalWorkingMemory wm)
createMemory
in interface MemoryFactory<ReactiveFromNode.ReactiveFromMemory>
createMemory
in class FromNode<ReactiveFromNode.ReactiveFromMemory>
public short getType()
getType
in interface NetworkNode
getType
in class FromNode<ReactiveFromNode.ReactiveFromMemory>
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.