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
ConstructorsConstructorDescriptionEventResultReceiver(InterruptFlag interruptFlag, int arity, ReasoningMonitor monitor) EventResultReceiver(InterruptFlag interruptFlag, ReasoningMonitor monitor) -
Method Summary
Modifier and TypeMethodDescriptionabstract SymbolTableget the symboltable to decode the resultsbooleanreceiveRelation(ReasoningRelation tuples) receive a whole relationabstract voidreceiveResult(long[] result) a new result has been receivedabstract voidreceiveResult(TupleBuffer result) a new result has been receivedabstract voidretractResult(long[] result) a new result should be withdrawnabstract voidsetSymbolTable(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:Receiverreceive a whole relation- Specified by:
receiveRelationin interfaceReceiver- Overrides:
receiveRelationin classProcessImp- Parameters:
tuples- the whole relation to be received- Returns:
- true, if relation is later on dissolved, false otherwise
- Throws:
ReasoningExceptionInterruptedExceptionIOExceptionSemReasonerException
-
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:
IOExceptionReasoningException
-
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:
-