Package tools.refinery.interpreter.rete.single

Class TimelyUniquenessEnforcerNode

java.lang.Object

tools.refinery.interpreter.rete.network.BaseNode

tools.refinery.interpreter.rete.network.StandardNode

tools.refinery.interpreter.rete.single.AbstractUniquenessEnforcerNode

tools.refinery.interpreter.rete.single.TimelyUniquenessEnforcerNode

All Implemented Interfaces:

ResumableNode, IGroupable, NetworkStructureChangeSensitiveNode, Node, Receiver, Supplier, Tunnel

Direct Known Subclasses:

TimelyProductionNode

public class TimelyUniquenessEnforcerNode
extends AbstractUniquenessEnforcerNode
implements ResumableNode

Timely uniqueness enforcer node implementation.

Since:

2.4

Field Summary

Fields

Modifier and Type	Field	Description
protected CommunicationGroup	group
protected final TimelyMemory<Timestamp>	memory

Fields inherited from class tools.refinery.interpreter.rete.single.AbstractUniquenessEnforcerNode

identityMask, mailbox, memoryIdentityIndexer, memoryNullIndexer, nullMask, parents, specializedListeners, tupleWidth

Fields inherited from class tools.refinery.interpreter.rete.network.StandardNode

childMailboxes, children

Fields inherited from class tools.refinery.interpreter.rete.network.BaseNode

nodeId, reteContainer, tag, traceInfos

Constructor Summary

Constructors

Constructor	Description
TimelyUniquenessEnforcerNode(ReteContainer container, int tupleWidth)

Method Summary

Modifier and Type	Method	Description
CommunicationGroup	getCurrentGroup()
ProjectionIndexer	getIdentityIndexer()
ProjectionIndexer	getNullIndexer()
Timestamp	getResumableTimestamp()	Returns the smallest timestamp where lazy folding shall be resumed, or null if there is no more folding to do in this resumable.
Set<Tuple>	getTuples()
protected Mailbox	instantiateMailbox()
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	resumeAt(Timestamp timestamp)	When called, the folding of the state shall be resumed at the given timestamp.
void	setCurrentGroup(CommunicationGroup group)	Sets the current group of the mailbox
void	update(Direction direction, Tuple update, Timestamp timestamp)	Updates the receiver with a newly found or lost partial matching.

Methods inherited from class tools.refinery.interpreter.rete.single.AbstractUniquenessEnforcerNode

appendParent, assignTraceInfo, constructIndex, getMailbox, getParents, propagate, removeParent

Methods inherited from class tools.refinery.interpreter.rete.network.StandardNode

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

Methods inherited from class tools.refinery.interpreter.rete.network.BaseNode

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface tools.refinery.interpreter.rete.network.Node

acceptPropagatedTraceInfo, assignTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTag

Methods inherited from interface tools.refinery.interpreter.rete.network.Receiver

batchUpdate

Methods inherited from interface tools.refinery.interpreter.rete.network.Supplier

appendChild, getPulledContents, getPulledContents, getReceivers, removeChild

Field Details

memory

protected final TimelyMemory<Timestamp> memory

group

protected CommunicationGroup group

Since:

2.4

Constructor Details

TimelyUniquenessEnforcerNode

public TimelyUniquenessEnforcerNode(ReteContainer container,
 int tupleWidth)

Method Details

instantiateMailbox

protected Mailbox instantiateMailbox()

Specified by:

instantiateMailbox in class AbstractUniquenessEnforcerNode

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

getCurrentGroup

public CommunicationGroup getCurrentGroup()

Specified by:

getCurrentGroup in interface IGroupable

Returns:

the current group of the mailbox

setCurrentGroup

public void setCurrentGroup(CommunicationGroup group)

Description copied from interface: IGroupable

Sets the current group of the mailbox

Specified by:

setCurrentGroup in interface IGroupable

getTuples

public Set<Tuple> getTuples()

Specified by:

getTuples in class AbstractUniquenessEnforcerNode

getResumableTimestamp

public Timestamp getResumableTimestamp()

Description copied from interface: ResumableNode

Returns the smallest timestamp where lazy folding shall be resumed, or null if there is no more folding to do in this resumable.

Specified by:

getResumableTimestamp in interface ResumableNode

Since:

2.4

resumeAt

public void resumeAt(Timestamp timestamp)

Description copied from interface: ResumableNode

When called, the folding of the state shall be resumed at the given timestamp. The resumable is expected to do a folding step at the given timestamp only. Afterwards, folding shall be interrupted, even if there is more folding to do towards higher timestamps.

Specified by:

resumeAt in interface ResumableNode

Since:

2.4

update

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

Description copied from interface: Receiver

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

Specified by:

update in interface Receiver

pullIntoWithTimeline

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

Specified by:

pullIntoWithTimeline in interface Supplier

getNullIndexer

public ProjectionIndexer getNullIndexer()

Specified by:

getNullIndexer in class AbstractUniquenessEnforcerNode

getIdentityIndexer

public ProjectionIndexer getIdentityIndexer()

Specified by:

getIdentityIndexer in class AbstractUniquenessEnforcerNode

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