public class AccumulateNode extends BetaNode
Modifier and Type | Class and Description |
---|---|
static class |
AccumulateNode.AccumulateContext |
static class |
AccumulateNode.AccumulateMemory |
static class |
AccumulateNode.ActivitySource |
static class |
AccumulateNode.MultiAccumulateMemory |
static class |
AccumulateNode.SingleAccumulateMemory |
Modifier and Type | Field and Description |
---|---|
protected Accumulate |
accumulate |
protected BetaConstraints |
resultBinder |
protected AlphaNodeFieldConstraint[] |
resultConstraints |
protected boolean |
unwrapRightObject |
constraints, indexedUnificationJoin, isLogTraceEnabled, log, objectMemory, rightInput, tupleMemoryEnabled
leftInput, sink
associations, hashcode, id, memoryId, partitionId, partitionsEnabled
Constructor and Description |
---|
AccumulateNode() |
AccumulateNode(int id,
LeftTupleSource leftInput,
ObjectSource rightInput,
AlphaNodeFieldConstraint[] resultConstraints,
BetaConstraints sourceBinder,
BetaConstraints resultBinder,
Accumulate accumulate,
boolean unwrapRightObject,
BuildContext context) |
assertObject, byPassModifyToBetaNode, createRightTuple, doDeleteRightTuple, doUpdateRightTuple, dumpMemory, getBetaMemory, getBetaMemoryFromRightInput, getConstraints, getFirstLeftTuple, getFirstRightTuple, getFirstTuple, getLeftIterator, getNextLeftTupleSinkNode, getNextObjectSinkNode, getObjectTypeNode, getPreviousLeftTupleSinkNode, getPreviousObjectSinkNode, getRawConstraints, getRightDeclaredMask, getRightInferredMask, getRightInput, getRightInputOtnId, getRightIterator, getRightIterator, getRightNegativeMask, getRules, initDeclaredMask, initInferredMask, initInferredMask, isIndexedUnificationJoin, isLeftTupleMemoryEnabled, isObjectMemoryEnabled, isRightInputIsRiaNode, isRightInputPassive, modifyObject, networkUpdated, setLeftListenedProperties, setLeftTupleMemoryEnabled, setNextLeftTupleSinkNode, setNextObjectSinkNode, setPartitionId, setPreviousLeftTupleSinkNode, setPreviousObjectSinkNode, setRightDeclaredMask, setRightInput, setRightInputOtnId, toString, unwrapRightInput
addTupleSink, addTupleSink, addTupleSink, getLeftDeclaredMask, getLeftInferredMask, getLeftInputOtnId, getLeftInputPattern, getLeftNegativeMask, getLeftTupleSource, getObjectType, getPositionInPath, getSinkPropagator, initMasks, isInUse, removeTupleSink, setLeftInferredMask, setLeftInputOtnId, setLeftTupleSource, setNodeConstraintsPropertyReactiveMask, setPartitionIdWithSinks, setSourcePartitionId, setSourcePartitionId
addAssociation, addAssociation, getAssociatedRules, getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getMemoryId, getPartitionId, getSinks, hashCode, initMemoryId, isAssociatedWith, isStreamMode, remove, removeAssociation, setId, setPartitionsEnabled, setStreamMode
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getLeftInferredMask, getLeftInputOtnId, setLeftInputOtnId, setPartitionIdWithSinks
getLeftTupleSource, getPositionInPath, getSinkPropagator
setPartitionIdWithSinks
getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, isAssociatedWith
getMemoryId
protected boolean unwrapRightObject
protected Accumulate accumulate
protected AlphaNodeFieldConstraint[] resultConstraints
protected BetaConstraints resultBinder
public AccumulateNode()
public AccumulateNode(int id, LeftTupleSource leftInput, ObjectSource rightInput, AlphaNodeFieldConstraint[] resultConstraints, BetaConstraints sourceBinder, BetaConstraints resultBinder, Accumulate accumulate, boolean unwrapRightObject, BuildContext context)
protected ObjectType getObjectTypeForPropertyReactivity(LeftInputAdapterNode leftInput, Pattern pattern)
getObjectTypeForPropertyReactivity
in class LeftTupleSource
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class BetaNode
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class BetaNode
IOException
public short getType()
getType
in interface NetworkNode
getType
in class LeftTupleSource
public Accumulate getAccumulate()
public AlphaNodeFieldConstraint[] getResultConstraints()
public BetaConstraints getResultBinder()
public boolean isUnwrapRightObject()
public InternalFactHandle createResultFactHandle(PropagationContext context, InternalWorkingMemory workingMemory, LeftTuple leftTuple, Object result)
public void attach(BuildContext context)
BaseNode
ObjectSource
or TupleSource
protected int calculateHashCode()
calculateHashCode
in class BetaNode
public Memory createMemory(RuleBaseConfiguration config, InternalWorkingMemory wm)
createMemory
in interface MemoryFactory
createMemory
in class BetaNode
public LeftTuple createLeftTuple(InternalFactHandle factHandle, Sink sink, boolean leftTupleMemoryEnabled)
public LeftTuple createLeftTuple(InternalFactHandle factHandle, LeftTuple leftTuple, Sink sink)
public LeftTuple createLeftTuple(LeftTuple leftTuple, Sink sink, PropagationContext pctx, boolean leftTupleMemoryEnabled)
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, Sink sink)
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, LeftTuple currentLeftChild, LeftTuple currentRightChild, Sink sink, boolean leftTupleMemoryEnabled)
public LeftTuple createPeer(LeftTuple original)
createPeer
in interface LeftTupleSink
createPeer
in class LeftTupleSource
public void retractRightTuple(RightTuple rightTuple, PropagationContext pctx, InternalWorkingMemory workingMemory)
public void modifyRightTuple(RightTuple rightTuple, PropagationContext context, InternalWorkingMemory workingMemory)
public boolean doRemove(RuleRemovalContext context, ReteooBuilder builder)
BaseNode
ObjectSource
or TupleSource
Copyright © 2001–2019 JBoss by Red Hat. All rights reserved.