org.drools.reteoo
Class CompositeObjectSinkAdapter

java.lang.Object
  extended by org.drools.reteoo.AbstractObjectSinkAdapter
      extended by org.drools.reteoo.CompositeObjectSinkAdapter
All Implemented Interfaces:
Externalizable, Serializable, ObjectSinkPropagator
Direct Known Subclasses:
AsyncCompositeObjectSinkAdapter

public class CompositeObjectSinkAdapter
extends AbstractObjectSinkAdapter

See Also:
Serialized Form

Nested Class Summary
static class CompositeObjectSinkAdapter.FieldIndex
           
static class CompositeObjectSinkAdapter.HashKey
           
 
Field Summary
 
Fields inherited from class org.drools.reteoo.AbstractObjectSinkAdapter
partitionId
 
Constructor Summary
CompositeObjectSinkAdapter()
           
CompositeObjectSinkAdapter(RuleBasePartitionId partitionId, int alphaNodeHashingThreshold)
           
 
Method Summary
 void addObjectSink(ObjectSink sink)
           
protected  void doPropagateAssertObject(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory, ObjectSink sink)
          This is a Hook method for subclasses to override.
protected  void doPropagateModifyObject(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory, ObjectSink sink)
           
 ObjectSinkNodeList getHashableSinks()
           
 ObjectHashMap getHashedSinkMap()
           
 BaseNode getMatchingNode(BaseNode candidate)
           
 ObjectSinkNodeList getOthers()
           
 ObjectSink[] getSinks()
           
 void propagateAssertObject(InternalFactHandle factHandle, PropagationContext context, InternalWorkingMemory workingMemory)
           
 void propagateModifyObject(InternalFactHandle factHandle, ModifyPreviousTuples modifyPreviousTuples, PropagationContext context, InternalWorkingMemory workingMemory)
           
 void readExternal(ObjectInput in)
           
 void removeObjectSink(ObjectSink sink)
           
 int size()
           
 void writeExternal(ObjectOutput out)
           
 
Methods inherited from class org.drools.reteoo.AbstractObjectSinkAdapter
getPartitionId, setPartitionId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CompositeObjectSinkAdapter

public CompositeObjectSinkAdapter()

CompositeObjectSinkAdapter

public CompositeObjectSinkAdapter(RuleBasePartitionId partitionId,
                                  int alphaNodeHashingThreshold)
Method Detail

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException
Specified by:
readExternal in interface Externalizable
Overrides:
readExternal in class AbstractObjectSinkAdapter
Throws:
IOException
ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException
Specified by:
writeExternal in interface Externalizable
Overrides:
writeExternal in class AbstractObjectSinkAdapter
Throws:
IOException

getOthers

public ObjectSinkNodeList getOthers()

getHashableSinks

public ObjectSinkNodeList getHashableSinks()

getHashedSinkMap

public ObjectHashMap getHashedSinkMap()

addObjectSink

public void addObjectSink(ObjectSink sink)

removeObjectSink

public void removeObjectSink(ObjectSink sink)

propagateAssertObject

public void propagateAssertObject(InternalFactHandle factHandle,
                                  PropagationContext context,
                                  InternalWorkingMemory workingMemory)

propagateModifyObject

public void propagateModifyObject(InternalFactHandle factHandle,
                                  ModifyPreviousTuples modifyPreviousTuples,
                                  PropagationContext context,
                                  InternalWorkingMemory workingMemory)

doPropagateAssertObject

protected void doPropagateAssertObject(InternalFactHandle factHandle,
                                       PropagationContext context,
                                       InternalWorkingMemory workingMemory,
                                       ObjectSink sink)
This is a Hook method for subclasses to override. Please keep it protected unless you know what you are doing.

Parameters:
factHandle -
context -
workingMemory -
sink -

doPropagateModifyObject

protected void doPropagateModifyObject(InternalFactHandle factHandle,
                                       ModifyPreviousTuples modifyPreviousTuples,
                                       PropagationContext context,
                                       InternalWorkingMemory workingMemory,
                                       ObjectSink sink)

getMatchingNode

public BaseNode getMatchingNode(BaseNode candidate)

getSinks

public ObjectSink[] getSinks()

size

public int size()


Copyright © 2001-2012 JBoss by Red Hat. All Rights Reserved.