Class RepresentativeElectionNode

java.lang.Object

tools.refinery.interpreter.rete.network.BaseNode

tools.refinery.interpreter.rete.network.StandardNode

tools.refinery.interpreter.rete.single.SingleInputNode

tools.refinery.interpreter.rete.single.RepresentativeElectionNode

All Implemented Interfaces:

Clearable, RepresentativeObserver<Object>, NetworkStructureChangeSensitiveNode, Node, Receiver, ReinitializedNode, Supplier, Tunnel

public class RepresentativeElectionNode
extends SingleInputNode
implements Clearable, RepresentativeObserver<Object>, ReinitializedNode

Field Summary

Fields inherited from class SingleInputNode

mailbox, parent

Fields inherited from class StandardNode

childMailboxes, children

Fields inherited from class BaseNode

nodeId, reteContainer, tag, traceInfos

Constructor Summary

Constructors

Constructor	Description
RepresentativeElectionNode(ReteContainer reteContainer, RepresentativeElectionAlgorithm.Factory algorithmFactory)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	networkStructureChanged()	At the time of the invocation, the dependency graph has already been updated.
void	pullInto(Collection<Tuple> collector, boolean flush)	Pulls the contents of this object in this particular moment into a target collection.
void	pullIntoWithTimeline(Map<Tuple, Timeline<Timestamp>> collector, boolean flush)
void	reinitializeWith(Collection<Tuple> tuples)
void	tupleChanged(Object source, Object representative, Direction direction)
void	update(Direction direction, Tuple updateElement, Timestamp timestamp)	Updates the receiver with a newly found or lost partial matching.

Methods inherited from class SingleInputNode

appendParent, assignTraceInfo, getCommunicationTracker, getMailbox, getParents, instantiateMailbox, propagatePullInto, propagatePullIntoWithTimestamp, removeParent

Methods inherited from class StandardNode

appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, propagateUpdate, removeChild

Methods inherited from class BaseNode

acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCore

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Node

acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTag

Methods inherited from interface Receiver

batchUpdate

Methods inherited from interface Supplier

appendChild, constructIndex, getPulledContents, getPulledContents, getReceivers, removeChild

Constructor Details

RepresentativeElectionNode

public RepresentativeElectionNode(ReteContainer reteContainer,
 RepresentativeElectionAlgorithm.Factory algorithmFactory)

Method Details

networkStructureChanged

public void networkStructureChanged()

Description copied from interface: NetworkStructureChangeSensitiveNode

At the time of the invocation, the dependency graph has already been updated.

Specified by:

networkStructureChanged in interface NetworkStructureChangeSensitiveNode

Overrides:

networkStructureChanged in class StandardNode

reinitializeWith

public void reinitializeWith(Collection<Tuple> tuples)

Specified by:

reinitializeWith in interface ReinitializedNode

tupleChanged

public void tupleChanged(Object source,
 Object representative,
 Direction direction)

Specified by:

tupleChanged in interface RepresentativeObserver<Object>

clear

public void clear()

Specified by:

clear in interface Clearable

update

public void update(Direction direction,
 Tuple updateElement,
 Timestamp timestamp)

Description copied from interface: Receiver

Updates the receiver with a newly found or lost partial matching.

Specified by:

update in interface Receiver

pullInto

public void pullInto(Collection<Tuple> collector,
 boolean flush)

Description copied from interface: Supplier

Pulls the contents of this object in this particular moment into a target collection.

Specified by:

pullInto in interface Supplier

Parameters:

flush - if true, flushing of messages is allowed during the pull, otherwise flushing is not allowed

pullIntoWithTimeline

public void pullIntoWithTimeline(Map<Tuple, Timeline<Timestamp>> collector,
 boolean flush)

Specified by:

pullIntoWithTimeline in interface Supplier