public class EntryPointNode extends ObjectSource implements Externalizable, ObjectSink
ObjectTypeNode
,
Serialized FormModifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
log |
protected Map<ObjectType,ObjectTypeNode> |
objectTypeNodes
The object type nodes under this node
|
protected ObjectTypeNode |
queryNode |
declaredMask, inferredMask, sink, source
associations, id, partitionId, partitionsEnabled
Constructor and Description |
---|
EntryPointNode() |
EntryPointNode(int id,
ObjectSource objectSource,
BuildContext context) |
EntryPointNode(int id,
RuleBasePartitionId partitionId,
boolean partitionsEnabled,
ObjectSource objectSource,
EntryPointId entryPoint) |
getDeclaredMask, getKnowledgeBase, getObjectTypeNode, getParentObjectSource, getSinkPropagator, initDeclaredMask, isInUse, networkUpdated, resetInferredMask, updateMask
addAssociation, getAssociations, getId, getPartitionId, isStreamMode, remove, removeAssociation, setId, setPartitionId, setStreamMode
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getAssociations, getId, getPartitionId
protected static final transient org.slf4j.Logger log
protected Map<ObjectType,ObjectTypeNode> objectTypeNodes
protected ObjectTypeNode queryNode
public EntryPointNode()
public EntryPointNode(int id, ObjectSource objectSource, BuildContext context)
public EntryPointNode(int id, RuleBasePartitionId partitionId, boolean partitionsEnabled, ObjectSource objectSource, EntryPointId entryPoint)
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 short getType()
getType
in interface NetworkNode
public EntryPointId getEntryPoint()
public void assertQuery(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public void retractQuery(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public void modifyQuery(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public ObjectTypeNode getQueryNode()
public void assertActivation(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public void retractActivation(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public void modifyActivation(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
public void assertObject(InternalFactHandle handle, PropagationContext context, ObjectTypeConf objectTypeConf, InternalWorkingMemory workingMemory)
public void modifyObject(InternalFactHandle handle, PropagationContext pctx, ObjectTypeConf objectTypeConf, InternalWorkingMemory workingMemory)
public void propagateModify(InternalFactHandle handle, PropagationContext pctx, ObjectTypeConf objectTypeConf, InternalWorkingMemory wm)
public void doDeleteObject(PropagationContext pctx, InternalWorkingMemory wm, LeftTuple leftTuple)
public void doRightDelete(PropagationContext pctx, InternalWorkingMemory wm, RightTuple rightTuple)
public void modifyObject(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory)
modifyObject
in interface ObjectSink
public void assertObject(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
ObjectTypdeNode
s asserting the Fact. If the cache does not
exist it first iterates and builds the cache.assertObject
in interface ObjectSink
factHandle
- The FactHandle of the fact to assertcontext
- The PropagationContext
of the WorkingMemory
actionworkingMemory
- The working memory session.public void retractObject(InternalFactHandle handle, PropagationContext context, ObjectTypeConf objectTypeConf, InternalWorkingMemory workingMemory)
RuleBase
and the specified
WorkingMemory
.handle
- The handle of the fact to retract.workingMemory
- The working memory session.public void propagateRetract(InternalFactHandle handle, PropagationContext context, ObjectTypeConf objectTypeConf, InternalWorkingMemory workingMemory)
public void addObjectSink(ObjectSink objectSink)
ObjectSink
so that it may receive
Objects
propagated from this ObjectSource
.addObjectSink
in class ObjectSource
objectSink
- The ObjectSink
to receive propagated
Objects
. Rete only accepts ObjectTypeNode
s
as parameters to this method, though.public boolean removeObjectSink(ObjectSink objectSink)
ObjectSource
ObjectSink
removeObjectSink
in class ObjectSource
objectSink
- The ObjectSink
to removepublic void attach()
public void attach(BuildContext context)
BaseNode
ObjectSource
or TupleSource
protected boolean doRemove(RuleRemovalContext context, ReteooBuilder builder, InternalWorkingMemory[] workingMemories)
BaseNode
ObjectSource
or TupleSource
doRemove
in class ObjectSource
public Map<ObjectType,ObjectTypeNode> getObjectTypeNodes()
public int hashCode()
BaseNode
public void updateSink(ObjectSink sink, PropagationContext context, InternalWorkingMemory workingMemory)
updateSink
in class ObjectSource
public void byPassModifyToBetaNode(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory)
byPassModifyToBetaNode
in interface ObjectSink
public BitMask calculateDeclaredMask(List<String> settableProperties)
calculateDeclaredMask
in class ObjectSource
Copyright © 2001–2015 JBoss by Red Hat. All rights reserved.