public class FromNode extends LeftTupleSource implements LeftTupleSinkNode, MemoryFactory
Modifier and Type | Class and Description |
---|---|
static class |
FromNode.FromMemory |
Modifier and Type | Field and Description |
---|---|
protected AlphaNodeFieldConstraint[] |
alphaConstraints |
protected BetaConstraints |
betaConstraints |
protected DataProvider |
dataProvider |
protected From |
from |
protected LeftTupleSinkNode |
nextTupleSinkNode |
protected ObjectTypeConf |
objectTypeConf |
protected LeftTupleSinkNode |
previousTupleSinkNode |
protected Class<?> |
resultClass |
protected boolean |
tupleMemoryEnabled |
leftInput, sink
associations, id, partitionId, partitionsEnabled, streamMode
Constructor and Description |
---|
FromNode() |
FromNode(int id,
DataProvider dataProvider,
LeftTupleSource tupleSource,
AlphaNodeFieldConstraint[] constraints,
BetaConstraints binder,
boolean tupleMemoryEnabled,
BuildContext context,
From from) |
addTupleSink, addTupleSink, addTupleSink, getLeftDeclaredMask, getLeftInferredMask, getLeftInputOtnId, getLeftNegativeMask, getObjectType, getSinkPropagator, initDeclaredMask, initInferredMask, initMasks, isInUse, removeTupleSink, setLeftInferredMask, setLeftInputOtnId, setLeftListenedProperties, setLeftTupleSource
addAssociation, attach, getAssociations, getId, getPartitionId, hashCode, isStreamMode, remove, removeAssociation, setId, setPartitionId, toString
clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait
getLeftInferredMask, getLeftInputOtnId, setLeftInputOtnId
getAssociations, getId, getPartitionId
getId
protected DataProvider dataProvider
protected AlphaNodeFieldConstraint[] alphaConstraints
protected BetaConstraints betaConstraints
protected LeftTupleSinkNode previousTupleSinkNode
protected LeftTupleSinkNode nextTupleSinkNode
protected From from
protected Class<?> resultClass
protected boolean tupleMemoryEnabled
protected transient ObjectTypeConf objectTypeConf
public FromNode()
public FromNode(int id, DataProvider dataProvider, LeftTupleSource tupleSource, AlphaNodeFieldConstraint[] constraints, BetaConstraints binder, boolean tupleMemoryEnabled, BuildContext context, From from)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class LeftTupleSource
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class LeftTupleSource
IOException
public DataProvider getDataProvider()
public AlphaNodeFieldConstraint[] getAlphaConstraints()
public BetaConstraints getBetaConstraints()
public Class<?> getResultClass()
public void networkUpdated(UpdateContext updateContext)
BaseNode
networkUpdated
in class BaseNode
public RightTuple createRightTuple(LeftTuple leftTuple, PropagationContext context, InternalWorkingMemory workingMemory, Object object)
protected RightTuple newRightTuple(InternalFactHandle handle, Object o)
public void addToCreatedHandlesMap(Map<Object,RightTuple> matches, RightTuple rightTuple)
public Memory createMemory(RuleBaseConfiguration config, InternalWorkingMemory wm)
createMemory
in interface MemoryFactory
public LeftTuple createPeer(LeftTuple original)
createPeer
in interface LeftTupleSink
createPeer
in class LeftTupleSource
public boolean isLeftTupleMemoryEnabled()
isLeftTupleMemoryEnabled
in interface LeftTupleSink
isLeftTupleMemoryEnabled
in class LeftTupleSource
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
getType
in interface LeftTupleSink
getType
in class LeftTupleSource
public LeftTuple createLeftTuple(InternalFactHandle factHandle, LeftTupleSink sink, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(InternalFactHandle factHandle, LeftTuple leftTuple, LeftTupleSink sink)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, LeftTupleSink sink, PropagationContext pctx, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, LeftTupleSink sink)
createLeftTuple
in interface LeftTupleSink
public LeftTuple createLeftTuple(LeftTuple leftTuple, RightTuple rightTuple, LeftTuple currentLeftChild, LeftTuple currentRightChild, LeftTupleSink sink, boolean leftTupleMemoryEnabled)
createLeftTuple
in interface LeftTupleSink
public LeftTupleSource getLeftTupleSource()
getLeftTupleSource
in interface LeftTupleSink
getLeftTupleSource
in class LeftTupleSource
protected ObjectTypeNode getObjectTypeNode()
getObjectTypeNode
in class LeftTupleSource
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 void modifyLeftTuple(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory)
modifyLeftTuple
in interface LeftTupleSink
public void updateSink(LeftTupleSink sink, PropagationContext context, InternalWorkingMemory workingMemory)
updateSink
in class LeftTupleSource
public void modifyLeftTuple(LeftTuple leftTuple, PropagationContext context, InternalWorkingMemory workingMemory)
modifyLeftTuple
in interface LeftTupleSink
public void attach(BuildContext context)
BaseNode
ObjectSource
or TupleSource
protected void doRemove(RuleRemovalContext context, ReteooBuilder builder, InternalWorkingMemory[] workingMemories)
BaseNode
ObjectSource
or TupleSource
Copyright © 2001-2014 JBoss by Red Hat. All Rights Reserved.