Package | Description |
---|---|
org.eclipse.incquery.runtime.rete.boundary | |
org.eclipse.incquery.runtime.rete.network | |
org.eclipse.incquery.runtime.rete.remote |
Modifier and Type | Method and Description |
---|---|
Address<? extends Production> |
ReteBoundary.accessProductionNode(PQuery query)
accesses the production node for specified pattern; builds pattern matcher if it doesn't exist yet
|
Address<? extends Supplier> |
ReteBoundary.getAddress(SubPlan plan) |
Address<ExternalInputEnumeratorNode> |
InputConnector.getExternalInputNode(IInputKey inputKey,
Tuple seed) |
Address<ExternalInputEnumeratorNode> |
InputConnector.getExternalInputNodeForKeyUnseeded(IInputKey inputKey) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Address<ExternalInputEnumeratorNode>> |
InputConnector.getAllExternalInputNodes() |
java.util.Collection<Address<ExternalInputEnumeratorNode>> |
InputConnector.getAllExternalInputNodesForKey(IInputKey inputKey) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<SubPlan> |
ReteBoundary.getParentPlansOfReceiver(Address<? extends Receiver> receiver)
Deprecated.
|
void |
ReteBoundary.mapPlanToAddress(SubPlan plan,
Address<? extends Supplier> handle) |
void |
ReteBoundary.notifyEvaluator(Address<? extends Receiver> receiver,
Tuple tuple) |
void |
ReteBoundary.registerParentPlanForReceiver(Address<? extends Receiver> receiver,
SubPlan parentPlan)
|
Modifier and Type | Method and Description |
---|---|
Address<? extends Node> |
Network.getExistingNodeByRecipe(ReteNodeRecipe recipe) |
Address<? extends Node> |
Network.getNodeByRecipeIfExists(ReteNodeRecipe recipe) |
Address<? extends Node> |
NodeProvisioner.getOrCreateNodeByRecipe(RecipeTraceInfo recipeTrace) |
<N extends Node> |
ReteContainer.makeAddress(N node)
Provides an external address for the selected node.
|
Modifier and Type | Method and Description |
---|---|
Supplier |
NodeProvisioner.asSupplier(Address<? extends Supplier> address)
The powerful method for accessing any (supplier) Address as a local supplier.
|
void |
ReteContainer.connectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean synchronise)
Establishes connection between a supplier and a receiver node, regardless which container they are in.
|
void |
ReteContainer.connectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean synchronise)
Establishes connection between a supplier and a receiver node, regardless which container they are in.
|
void |
Network.connectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean synchronise)
Establishes connection between a supplier and a receiver node, regardless which container they are in.
|
void |
Network.connectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean synchronise)
Establishes connection between a supplier and a receiver node, regardless which container they are in.
|
void |
ReteContainer.connectRemoteSupplier(Address<? extends Supplier> supplier,
Receiver receiver,
boolean synchronise)
Establishes connection between a remote supplier and a local receiver node.
|
void |
ReteContainer.disconnectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean desynchronise)
Severs connection between a supplier and a receiver node, regardless which container they are in.
|
void |
ReteContainer.disconnectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean desynchronise)
Severs connection between a supplier and a receiver node, regardless which container they are in.
|
void |
Network.disconnectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean desynchronise)
Severs connection between a supplier and a receiver node, regardless which container they are in.
|
void |
Network.disconnectRemoteNodes(Address<? extends Supplier> supplier,
Address<? extends Receiver> receiver,
boolean desynchronise)
Severs connection between a supplier and a receiver node, regardless which container they are in.
|
void |
ReteContainer.disconnectRemoteSupplier(Address<? extends Supplier> supplier,
Receiver receiver,
boolean desynchronise)
Severs connection between a remote supplier and a local receiver node.
|
boolean |
ReteContainer.isLocal(Address<? extends Node> address)
Checks whether a certain address points to a node at this container.
|
java.util.Map<java.lang.String,java.lang.Integer> |
ReteContainer.remotePosMapping(Address<? extends Production> production)
Proxies for the getPosMapping() of Production nodes.
|
java.util.Collection<Tuple> |
ReteContainer.remotePull(Address<? extends Supplier> supplier)
Retrieves the contents of a supplier for a remote caller.
|
<N extends Node> |
ReteContainer.resolveLocal(Address<N> address)
Returns an addressed node at this container.
|
void |
Network.sendConstructionUpdate(Address<? extends Receiver> receiver,
Direction direction,
Tuple updateElement)
Sends an update message to the receiver node, indicating a newly found or lost partial matching.
|
void |
Network.sendConstructionUpdates(Address<? extends Receiver> receiver,
Direction direction,
java.util.Collection<Tuple> updateElements)
Sends multiple update messages atomically to the receiver node, indicating a newly found or lost partial
matching.
|
void |
Network.sendExternalUpdate(Address<? extends Receiver> receiver,
Direction direction,
Tuple updateElement)
Sends an update message to the receiver node, indicating a newly found or lost partial matching.
|
void |
ReteContainer.sendUpdateToRemoteAddress(Address<? extends Receiver> address,
Direction direction,
Tuple updateElement)
Sends an update message to a node in a different container.
|
Modifier and Type | Method and Description |
---|---|
static <N extends Node> |
Address.of(N node)
Address of local node (use only for containers in the same VM!)
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteReceiver.addTarget(Address<? extends Receiver> target) |