Package com.semedy.reasoner.api.core
Class EventResultReceiver
java.lang.Object
com.semedy.reasoner.reasoning.processes.ProcessImp
com.semedy.reasoner.api.core.EventResultReceiver
- Direct Known Subclasses:
EmptyEventResultReceiver
,MaterializationReceiver
,StoreEventResultReceiver
A receiver for results caused by events
- Author:
- angele
-
Constructor Summary
ConstructorDescriptionEventResultReceiver
(InterruptFlag interruptFlag, int arity, ReasoningMonitor monitor) EventResultReceiver
(InterruptFlag interruptFlag, ReasoningMonitor monitor) -
Method Summary
Modifier and TypeMethodDescriptionabstract SymbolTable
get the symboltable to decode the resultsboolean
receiveRelation
(ReasoningRelation tuples) receive a whole relationabstract void
receiveResult
(long[] result) a new result has been receivedabstract void
receiveResult
(TupleBuffer result) a new result has been receivedabstract void
retractResult
(long[] result) a new result should be withdrawnabstract void
setSymbolTable
(SymbolTable symbols) set the symbol table to decode the resultsMethods inherited from class com.semedy.reasoner.reasoning.processes.ProcessImp
addNextReceiver, addRelation, clear, dispose, evaluate, evaluationFinished, evaluationFinished, getArity, getPriority, getStratum, getTupleStore, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, receiveTuple, receiveTuple, receiveTuple, setDataFlowGraph, setQueued, setStratum, startTuples, tuplesFinished, tuplesFinished
-
Constructor Details
-
EventResultReceiver
- Parameters:
interruptFlag
-
-
EventResultReceiver
-
-
Method Details
-
receiveRelation
public boolean receiveRelation(ReasoningRelation tuples) throws SemReasonerException, InterruptedException, IOException Description copied from interface:Receiver
receive a whole relation- Specified by:
receiveRelation
in interfaceReceiver
- Overrides:
receiveRelation
in classProcessImp
- Parameters:
tuples
- the whole relation to be received- Returns:
- true, if relation is later on dissolved, false otherwise
- Throws:
ReasoningException
InterruptedException
IOException
SemReasonerException
-
receiveResult
public abstract void receiveResult(long[] result) throws ReasoningException, IOException, SemReasonerException a new result has been received -
retractResult
a new result should be withdrawn- Throws:
IOException
ReasoningException
-
receiveResult
public abstract void receiveResult(TupleBuffer result) throws ReasoningException, IOException, SemReasonerException a new result has been received -
setSymbolTable
set the symbol table to decode the results- Parameters:
symbols
-
-
getSymbolTable
get the symboltable to decode the results- Returns:
-