public abstract class LeftTupleSource extends BaseNode implements LeftTupleNode, Externalizable
ReteTuple
s for a TupleSink
.
Nodes that propagate Tuples
extend this class.
LeftTupleSource
,
LeftTuple
,
Serialized FormModifier and Type | Field and Description |
---|---|
protected LeftTupleSource |
leftInput
The left input
TupleSource . |
protected LeftTupleSinkPropagator |
sink
The destination for
Tuples . |
associations, hashcode, id, memoryId, partitionId, partitionsEnabled
Modifier | Constructor and Description |
---|---|
|
LeftTupleSource() |
protected |
LeftTupleSource(int id,
BuildContext context)
Single parameter constructor that specifies the unique id of the node.
|
addAssociation, addAssociation, attach, doRemove, getAssociatedRules, getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getMemoryId, getObjectTypeNode, getPartitionId, getSinks, hashCode, initMemoryId, isAssociatedWith, isStreamMode, networkUpdated, remove, removeAssociation, setId, setPartitionId, setPartitionsEnabled, setStreamMode, toString
clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait
getAssociatedRuleSize, getAssociationsSize, getAssociationsSize, getId, getPartitionId, isAssociatedWith
protected LeftTupleSource leftInput
TupleSource
.protected LeftTupleSinkPropagator sink
Tuples
.public LeftTupleSource()
protected LeftTupleSource(int id, BuildContext context)
id
- public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class BaseNode
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class BaseNode
IOException
public int getPositionInPath()
getPositionInPath
in interface LeftTupleNode
public abstract short getType()
getType
in interface NetworkNode
public void addTupleSink(LeftTupleSink tupleSink)
public LeftTupleSource getLeftTupleSource()
getLeftTupleSource
in interface LeftTupleNode
public final void setLeftTupleSource(LeftTupleSource leftInput)
public void addTupleSink(LeftTupleSink tupleSink, BuildContext context)
TupleSink
so that it may receive
Tuples
propagated from this TupleSource
.tupleSink
- The TupleSink
to receive propagated
Tuples
.protected LeftTupleSinkPropagator addTupleSink(LeftTupleSinkPropagator sinkPropagator, LeftTupleSink tupleSink, BuildContext context)
public void removeTupleSink(LeftTupleSink tupleSink)
TupleSink
tupleSink
- The TupleSink
to removepublic LeftTupleSinkPropagator getSinkPropagator()
getSinkPropagator
in interface LeftTupleNode
public void setSourcePartitionId(BuildContext context, RuleBasePartitionId partitionId)
protected void setSourcePartitionId(BaseNode source, BuildContext context, RuleBasePartitionId partitionId)
public final void setPartitionIdWithSinks(RuleBasePartitionId partitionId)
public boolean isInUse()
BaseNode
protected final void initMasks(BuildContext context, LeftTupleSource leftInput)
protected void initDeclaredMask(BuildContext context, LeftTupleSource leftInput)
protected Pattern getLeftInputPattern(BuildContext context)
protected ObjectType getObjectTypeForPropertyReactivity(LeftInputAdapterNode leftInput, Pattern pattern)
protected void setLeftListenedProperties(Collection<String> leftListenedProperties)
protected void initInferredMask(LeftTupleSource leftInput)
public BitMask getLeftDeclaredMask()
public BitMask getLeftInferredMask()
protected void setLeftInferredMask(BitMask leftInferredMask)
public BitMask getLeftNegativeMask()
public ObjectTypeNode.Id getLeftInputOtnId()
public void setLeftInputOtnId(ObjectTypeNode.Id leftInputOtnId)
public ObjectType getObjectType()
public abstract boolean isLeftTupleMemoryEnabled()
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.