public abstract class LeftTupleSource extends BaseNode implements 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, id, 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, attach, attach, doRemove, getAssociations, getId, getPartitionId, hashCode, isStreamMode, networkUpdated, remove, removeAssociation, setId, setPartitionId, setStreamMode, toString
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 abstract short getType()
getType
in interface NetworkNode
public void addTupleSink(LeftTupleSink tupleSink)
public LeftTupleSource getLeftTupleSource()
public 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()
public abstract void updateSink(LeftTupleSink sink, PropagationContext context, InternalWorkingMemory workingMemory)
public boolean isInUse()
BaseNode
protected final void initMasks(BuildContext context, LeftTupleSource leftInput)
protected void initDeclaredMask(BuildContext context, LeftTupleSource leftInput)
protected void setLeftListenedProperties(List<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)
protected abstract ObjectTypeNode getObjectTypeNode()
public ObjectType getObjectType()
public abstract boolean isLeftTupleMemoryEnabled()
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.