public interface Supplier extends Node
Modifier and Type | Method and Description |
---|---|
void |
appendChild(Receiver receiver)
appends a receiver that will continously receive insert and revoke updates from this supplier
|
ProjectionIndexer |
constructIndex(TupleMask mask,
TraceInfo... traces)
Instantiates (or reuses, depending on implementation) an index according to the given mask.
|
default java.util.Set<Tuple> |
getPulledContents() |
java.util.Set<Tuple> |
getPulledContents(boolean flush)
Returns the contents of this object in this particular moment.
|
java.util.Collection<Receiver> |
getReceivers()
lists receivers
|
void |
pullInto(java.util.Collection<Tuple> collector,
boolean flush)
Pulls the contents of this object in this particular moment into a target collection.
|
void |
pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector,
boolean flush) |
void |
removeChild(Receiver receiver)
removes a receiver
|
acceptPropagatedTraceInfo, assignTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTag
void pullInto(java.util.Collection<Tuple> collector, boolean flush)
flush
- if true, flushing of messages is allowed during the pull, otherwise flushing is not allowedvoid pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector, boolean flush)
java.util.Set<Tuple> getPulledContents(boolean flush)
TrimmerNode
).
Intended mainly for debug purposes; therefore flushing is performed only if explicitly requested
During runtime, flushing may be preferred; see ReteContainer#pullContents(Supplier)
default java.util.Set<Tuple> getPulledContents()
void appendChild(Receiver receiver)
void removeChild(Receiver receiver)
ProjectionIndexer constructIndex(TupleMask mask, TraceInfo... traces)
java.util.Collection<Receiver> getReceivers()