All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
ObjectSinkPropagator |
addObjectSink(ObjectSink sink,
int alphaNodeHashingThreshold) |
ObjectSinkPropagator |
asNonPartitionedSinkPropagator(int alphaNodeHashingThreshold) |
void |
byPassModifyToBetaNode(InternalFactHandle factHandle,
ModifyPreviousTuples modifyPreviousTuples,
PropagationContext context,
InternalWorkingMemory workingMemory) |
void |
changeSinkPartition(ObjectSink sink,
RuleBasePartitionId oldPartition,
RuleBasePartitionId newPartition,
int alphaNodeHashingThreshold) |
void |
doLinkRiaNode(InternalWorkingMemory wm) |
void |
doUnlinkRiaNode(InternalWorkingMemory wm) |
BaseNode |
getMatchingNode(BaseNode candidate) |
ObjectSinkPropagator[] |
getPartitionedPropagators() |
ObjectSink[] |
getSinks() |
int |
getUsedPartitionsCount() |
boolean |
isEmpty() |
boolean |
isHashed() |
void |
propagateAssertObject(InternalFactHandle factHandle,
PropagationContext context,
InternalWorkingMemory workingMemory) |
void |
propagateModifyObject(InternalFactHandle factHandle,
ModifyPreviousTuples modifyPreviousTuples,
PropagationContext context,
InternalWorkingMemory workingMemory) |
void |
propagateModifyObjectForPartition(InternalFactHandle handle,
ModifyPreviousTuples modifyPreviousTuples,
PropagationContext context,
InternalWorkingMemory wm,
int partition) |
void |
readExternal(ObjectInput in) |
ObjectSinkPropagator |
removeObjectSink(ObjectSink sink) |
int |
size() |
void |
writeExternal(ObjectOutput out) |