Package com.semedy.reasoner.api.core

Class MaterializationReceiver

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.api.core.EventResultReceiver

com.semedy.reasoner.api.core.MaterializationReceiver

All Implemented Interfaces:

Receiver, Process

public class MaterializationReceiver
extends EventResultReceiver

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

Author:

angele

Constructor Summary

Constructors

Constructor	Description
MaterializationReceiver(InterruptFlag interruptFlag, Literal literal, DeductiveDatabase ddb, ExtensionalDB edb, SymbolTable symbols, SymbolTable reasoningSymbols)

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
TupleStore	getTupleStore()	get the basic tuple store
void	receiveResult(long[] tuple)	Receive a new result as a tuple of codes.
void	receiveResult(TupleBuffer result)	Receive a new result as a tuple of codes.
boolean	receiveTuple(int tuple)	receive a single tuple
void	retractResult(long[] result)	a new result should be withdrawn
void	setSymbolTable(SymbolTable symbols)	set the symbol table to decode the results
Receiver	startTuples(Receiver source, boolean check4Duplicates)	start delivering single tuples
Object	substitute(Object t, Object[] substitutions)
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples

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, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, receiveTuple, receiveTuple, setDataFlowGraph, setQueued, setStratum, tuplesFinished

Methods inherited from class java.lang.Object

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

Constructor Details

MaterializationReceiver

public MaterializationReceiver(InterruptFlag interruptFlag,
 Literal literal,
 DeductiveDatabase ddb,
 ExtensionalDB edb,
 SymbolTable symbols,
 SymbolTable reasoningSymbols)

Method Details

receiveTuple

public boolean receiveTuple(int tuple)
                     throws InterruptedException,
IOException,
SemReasonerException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

Parameters:

tuple - the tuple to be received

Returns:

true if tuple has been used (tuple cannot be free'd up)

Throws:

InterruptedException

IOException

SemReasonerException

receiveResult

public void receiveResult(long[] tuple)
                   throws IOException,
SemReasonerException

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

SemReasonerException

startTuples

public Receiver startTuples(Receiver source,
 boolean check4Duplicates)
                     throws IOException,
EDBException

Description copied from interface: Receiver

start delivering single tuples

Specified by:

startTuples in interface Receiver

Overrides:

startTuples in class ProcessImp

Parameters:

source - , the delivering process

check4Duplicates - , check for duplicates in the target store

Returns:

an object receiving the results

Throws:

IOException

EDBException

tuplesFinished

public void tuplesFinished(boolean isBottomUp)
                    throws InterruptedException,
IOException,
SemReasonerException

Description copied from interface: Receiver

finish delivering single tuples

Specified by:

tuplesFinished in interface Receiver

Overrides:

tuplesFinished in class ProcessImp

Parameters:

isBottomUp - TODO

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

getTupleStore

public TupleStore getTupleStore()

Description copied from interface: Receiver

get the basic tuple store

Specified by:

getTupleStore in interface Process

Specified by:

getTupleStore in interface Receiver

Overrides:

getTupleStore in class ProcessImp

Returns:

the tuple store

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

substitute

public Object substitute(Object t,
 Object[] substitutions)
                  throws SemReasonerException,
IOException

Throws:

SemReasonerException

IOException

retractResult

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

Description copied from class: EventResultReceiver

a new result should be withdrawn

Specified by:

retractResult in class EventResultReceiver

Throws:

IOException

ReasoningException