public class RightInputAdapterNode extends ObjectSource implements LeftTupleSinkNode, PathEndNode, MemoryFactory<RightInputAdapterNode.RiaNodeMemory>
Modifier and Type | Class and Description |
---|---|
static class |
RightInputAdapterNode.RiaNodeMemory |
declaredMask, inferredMask, sink, source
associations, hashcode, id, partitionId, partitionsEnabled
Constructor and Description |
---|
RightInputAdapterNode() |
RightInputAdapterNode(int id,
LeftTupleSource source,
LeftTupleSource startTupleSource,
BuildContext context)
Constructor specifying the unique id of the node in the Rete network, the position of the propagating
FactHandleImpl in
ReteTuple and the source that propagates the receive ReteTuple |
addObjectSink, getDeclaredMask, getKnowledgeBase, getObjectSinkPropagator, getObjectTypeNode, getParentObjectSource, initDeclaredMask, isInUse, removeObjectSink, resetInferredMask, setParentObjectSource, updateMask
addAssociation, getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, getSinks, hashCode, isAssociatedWith, isStreamMode, remove, setId, setPartitionId, setStreamMode, thisNodeEquals
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, isAssociatedWith, thisNodeEquals
getId
public RightInputAdapterNode()
public RightInputAdapterNode(int id, LeftTupleSource source, LeftTupleSource startTupleSource, BuildContext context)
FactHandleImpl
in
ReteTuple
and the source that propagates the receive ReteTuples.
id
- Unique idsource
- The TupleSource
which propagates the received ReteTuple
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class ObjectSource
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class ObjectSource
IOException
public void setPathEndNodes(PathEndNode[] pathEndNodes)
setPathEndNodes
in interface PathEndNode
public PathEndNode[] getPathEndNodes()
getPathEndNodes
in interface PathEndNode
public LeftTupleSource getStartTupleSource()
public int getPositionInPath()
getPositionInPath
in interface LeftTupleNode
public RightInputAdapterNode.RiaNodeMemory createMemory(RuleBaseConfiguration config, InternalWorkingMemory wm)
createMemory
in interface MemoryFactory<RightInputAdapterNode.RiaNodeMemory>
public SubnetworkTuple createPeer(LeftTuple original)
createPeer
in interface LeftTupleSink
public void attach(BuildContext context)
BaseNode
ObjectSource
or TupleSource
public void networkUpdated(UpdateContext updateContext)
BaseNode
networkUpdated
in class ObjectSource
protected boolean doRemove(RuleRemovalContext context, ReteooBuilder builder, InternalWorkingMemory[] workingMemories)
BaseNode
ObjectSource
or TupleSource
doRemove
in class ObjectSource
public boolean isLeftTupleMemoryEnabled()
isLeftTupleMemoryEnabled
in interface LeftTupleSink
public void setLeftTupleMemoryEnabled(boolean tupleMemoryEnabled)
setLeftTupleMemoryEnabled
in interface LeftTupleSink
public LeftTupleSinkNode getNextLeftTupleSinkNode()
getNextLeftTupleSinkNode
in interface LeftTupleSinkNode
public void setNextLeftTupleSinkNode(LeftTupleSinkNode next)
setNextLeftTupleSinkNode
in interface LeftTupleSinkNode
next
- The next TupleSinkNodepublic LeftTupleSinkNode getPreviousLeftTupleSinkNode()
getPreviousLeftTupleSinkNode
in interface LeftTupleSinkNode
public void setPreviousLeftTupleSinkNode(LeftTupleSinkNode previous)
setPreviousLeftTupleSinkNode
in interface LeftTupleSinkNode
previous
- The previous TupleSinkNodepublic short getType()
getType
in interface NetworkNode
protected boolean internalEquals(Object object)
internalEquals
in class BaseNode
public LeftTuple createLeftTuple(InternalFactHandle factHandle, Sink sink, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(InternalFactHandle factHandle, LeftTuple leftTuple, Sink sink)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, Sink sink, PropagationContext pctx, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, Sink sink)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, LeftTuple currentLeftChild, LeftTuple currentRightChild, Sink sink, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTupleSource getLeftTupleSource()
getLeftTupleSource
in interface LeftTupleNode
public void setTupleSource(LeftTupleSource tupleSource)
public ObjectTypeNode.Id getLeftInputOtnId()
getLeftInputOtnId
in interface LeftTupleSink
public void setLeftInputOtnId(ObjectTypeNode.Id leftInputOtnId)
setLeftInputOtnId
in interface LeftTupleSink
public BitMask calculateDeclaredMask(List<String> settableProperties)
calculateDeclaredMask
in class ObjectSource
public BitMask getLeftInferredMask()
getLeftInferredMask
in interface LeftTupleSink
public void modifyLeftTuple(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory)
modifyLeftTuple
in interface LeftTupleSink
public void modifyLeftTuple(LeftTuple leftTuple, PropagationContext context, InternalWorkingMemory workingMemory)
modifyLeftTuple
in interface LeftTupleSink
public void updateSink(ObjectSink sink, PropagationContext context, InternalWorkingMemory workingMemory)
updateSink
in class ObjectSource
public void assertLeftTuple(LeftTuple leftTuple, PropagationContext context, InternalWorkingMemory workingMemory)
LeftTupleSink
ReteTuple
.assertLeftTuple
in interface LeftTupleSink
leftTuple
- The ReteTuple
to propagate.context
- The PropagationContext
of the WorkingMemory action
workingMemory
- the WorkingMemory
session.public void retractLeftTuple(LeftTuple leftTuple, PropagationContext context, InternalWorkingMemory workingMemory)
retractLeftTuple
in interface LeftTupleSink
public LeftTupleNode[] getPathNodes()
getPathNodes
in interface PathEndNode
public boolean hasPathNode(LeftTupleNode node)
hasPathNode
in interface PathEndNode
public LeftTupleSinkPropagator getSinkPropagator()
getSinkPropagator
in interface LeftTupleNode
public void addAssociation(BuildContext context, org.kie.api.definition.rule.Rule rule)
addAssociation
in class BaseNode
public boolean removeAssociation(org.kie.api.definition.rule.Rule rule)
BaseNode
removeAssociation
in class BaseNode
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.