Package com.semedy.reasoner.api.core

Class StoreEventResultReceiver

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.api.core.EventResultReceiver

com.semedy.reasoner.api.core.StoreEventResultReceiver

All Implemented Interfaces:

Receiver, Process

public class StoreEventResultReceiver
extends EventResultReceiver

Stores results during materialization in edb
Single events are buffered until reasoning is finished.

Author:

angele

Constructor Summary

Constructors

Constructor	Description
StoreEventResultReceiver(InterruptFlag interruptFlag, DeductiveDatabase ddb, String predicateSymbol, int arity, String tempDir, String edbDir, boolean isPersistent, boolean writeLock, ReasoningMonitor monitor)

Method Summary

Modifier and Type	Method	Description
void	evaluationFinished()	After finishing the evaluation the buffered results (either in a main memory relation or in a file) are stored in the edb.
void	evaluationFinished(long querykey)	After finishing the evaluation the buffered results (either in a main memory relation or in a file) are stored in the edb.
SymbolTable	getSymbolTable()	get the symboltable to decode the results
void	receiveResult(long[] result)	Receive a new result as a tuple of codes.
void	receiveResult(TupleBuffer result)	Receive a new result as a tuple of codes.
void	retractResult(long[] result)	retract a result
void	setSymbolTable(SymbolTable symbols)	set the symbol table to decode the results

Methods inherited from class com.semedy.reasoner.api.core.EventResultReceiver

receiveRelation

Methods inherited from class com.semedy.reasoner.reasoning.processes.ProcessImp

addNextReceiver, addRelation, clear, dispose, evaluate, getArity, getPriority, getStratum, getTupleStore, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, receiveTuple, receiveTuple, receiveTuple, setDataFlowGraph, setQueued, setStratum, startTuples, tuplesFinished, tuplesFinished

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StoreEventResultReceiver

public StoreEventResultReceiver(InterruptFlag interruptFlag,
 DeductiveDatabase ddb,
 String predicateSymbol,
 int arity,
 String tempDir,
 String edbDir,
 boolean isPersistent,
 boolean writeLock,
 ReasoningMonitor monitor)

Method Details

receiveResult

public void receiveResult(long[] result)
                   throws ReasoningException,
IOException

Receive a new result as a tuple of codes.
Buffer result either in a main memory relation (main memory case) or store it in a file (persistent case)

Specified by:

receiveResult in class EventResultReceiver

Throws:

IOException

ReasoningException

retractResult

public void retractResult(long[] result)
                   throws ReasoningException,
IOException

retract a result

Specified by:

retractResult in class EventResultReceiver

Throws:

IOException

ReasoningException

receiveResult

public void receiveResult(TupleBuffer result)
                   throws ReasoningException,
IOException

Receive a new result as a tuple of codes.
Buffer result either in a main memory relation (main memory case) or store it in a file (persistent case)

Specified by:

receiveResult in class EventResultReceiver

Throws:

IOException

ReasoningException

setSymbolTable

public void setSymbolTable(SymbolTable symbols)

Description copied from class: EventResultReceiver

set the symbol table to decode the results

Specified by:

setSymbolTable in class EventResultReceiver

getSymbolTable

public SymbolTable getSymbolTable()

Description copied from class: EventResultReceiver

get the symboltable to decode the results

Specified by:

getSymbolTable in class EventResultReceiver

Returns:

evaluationFinished

public void evaluationFinished()
                        throws SemReasonerException,
IOException

After finishing the evaluation the buffered results (either in a main memory relation or in a file)
are stored in the edb.
Codes which have been generated during reasoning (by a built-in or by a function) have to be reencoded
as the reasoning symbol table has different codes compared to the base symbol table.

Overrides:

evaluationFinished in class ProcessImp

Throws:

SemReasonerException

IOException

evaluationFinished

public void evaluationFinished(long querykey)
                        throws SemReasonerException,
IOException

After finishing the evaluation the buffered results (either in a main memory relation or in a file)
are stored in the edb.
Codes which have been generated during reasoning (by a built-in or by a function) have to be reencoded
as the reasoning symbol table has different codes compared to the base symbol table.

Specified by:

evaluationFinished in interface Process

Overrides:

evaluationFinished in class ProcessImp

Throws:

ReasoningException

SemReasonerException

IOException