Package com.semedy.reasoner.reasoning.processes

Class ResultReceiver

java.lang.Object

com.semedy.reasoner.reasoning.processes.ResultReceiver

All Implemented Interfaces:

Receiver

public class ResultReceiver
extends Object
implements Receiver

container which collects reasoning results

Author:

angele

Constructor Summary

Constructors

Constructor	Description
ResultReceiver(InterruptFlag interruptflag, Rule query, int arity, ReasoningMonitor monitor, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, long maxResults)

Method Summary

Modifier and Type	Method	Description
void	addRelation(ReasoningRelation relation)	add a whole relation at the beginning
void	evaluationFinished()
List<ReasoningRelation>	getAllReceivedTuples()
List<ReasoningRelation>	getAllReceivedTuples(boolean duplicatesEliminated)	return a list of all received tuples
int	getArity()	arity of the tuples
List<ReasoningRelation>	getResults(boolean duplicatesEliminated)
List<TupleEnumerator>	getResultsIterators(boolean duplicatesEliminated)	return a list of all received tuples
TupleStore	getTupleStore()	get the basic tuple store
boolean	receiveRelation(ReasoningRelation R)	receive a whole relation
final boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
final boolean	receiveTuple(TupleBuffer tuple)	receive a single tuple
boolean	resultContainsEDBRelations()
Receiver	startTuples(Receiver source, boolean check4Duplicates)	start delivering single tuples
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples
void	tuplesFinished(String annotation, ReasoningRelation R1, ReasoningRelation R2)	Finish delivering single tuples.
void	withdrawRelation(ReasoningRelation relation)
boolean	withdrawTuple(int tuple)

Methods inherited from class java.lang.Object

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

Constructor Details

ResultReceiver

public ResultReceiver(InterruptFlag interruptflag,
 Rule query,
 int arity,
 ReasoningMonitor monitor,
 boolean cepReasoning,
 boolean cepReasoningWithRetracts,
 String tempDir,
 boolean swapping,
 long maxResults)

Method Details

getArity

public int getArity()

Description copied from interface: Receiver

arity of the tuples

Specified by:

getArity in interface Receiver

Returns:

the arity of the receiver

receiveTuple

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

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

IOException

withdrawTuple

public boolean withdrawTuple(int tuple)

receiveTuple

public final boolean receiveTuple(TupleBuffer tuple)
                           throws SemReasonerException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

ReasoningException

SemReasonerException

IOException

getAllReceivedTuples

public List<ReasoningRelation> getAllReceivedTuples()
                                             throws IOException,
EDBException

Throws:

IOException

EDBException

getAllReceivedTuples

public List<ReasoningRelation> getAllReceivedTuples(boolean duplicatesEliminated)
                                             throws IOException,
EDBException

return a list of all received tuples

Throws:

IOException

EDBException

getResultsIterators

public List<TupleEnumerator> getResultsIterators(boolean duplicatesEliminated)
                                          throws IOException,
EDBException

return a list of all received tuples

Throws:

IOException

EDBException

resultContainsEDBRelations

public boolean resultContainsEDBRelations()

getResults

public List<ReasoningRelation> getResults(boolean duplicatesEliminated)
                                   throws IOException,
EDBException

Throws:

IOException

EDBException

receiveRelation

public boolean receiveRelation(ReasoningRelation R)
                        throws SemReasonerException,
InterruptedException

Description copied from interface: Receiver

receive a whole relation

Specified by:

receiveRelation in interface Receiver

Parameters:

R - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

SemReasonerException

startTuples

public Receiver startTuples(Receiver source,
 boolean check4Duplicates)

Description copied from interface: Receiver

start delivering single tuples

Specified by:

startTuples in interface Receiver

Parameters:

source - , the delivering process

check4Duplicates - , check for duplicates in the target store

Returns:

an object receiving the results

tuplesFinished

public void tuplesFinished(boolean isBottomUp)
                    throws SemReasonerException,
InterruptedException

Description copied from interface: Receiver

finish delivering single tuples

Specified by:

tuplesFinished in interface Receiver

Parameters:

isBottomUp - TODO

Throws:

ReasoningException

SemReasonerException

InterruptedException

tuplesFinished

public void tuplesFinished(String annotation,
 ReasoningRelation R1,
 ReasoningRelation R2)
                    throws SemReasonerException,
InterruptedException

Description copied from interface: Receiver

Finish delivering single tuples.
Cache result and annotate result.

Specified by:

tuplesFinished in interface Receiver

Parameters:

annotation - , an annotation used for caching

R1 - , the relations which have been combined

R2 - , the relations which have been combined

Throws:

ReasoningException

SemReasonerException

InterruptedException

evaluationFinished

public void evaluationFinished()
                        throws SemReasonerException

Throws:

SemReasonerException

addRelation

public void addRelation(ReasoningRelation relation)

Description copied from interface: Receiver

add a whole relation at the beginning

Specified by:

addRelation in interface Receiver

Parameters:

relation - the relation to be added

getTupleStore

public TupleStore getTupleStore()

Description copied from interface: Receiver

get the basic tuple store

Specified by:

getTupleStore in interface Receiver

Returns:

the tuple store

receiveTuple

public boolean receiveTuple(long[] tuple)
                     throws SemReasonerException,
InterruptedException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

InterruptedException

IOException

withdrawRelation

public void withdrawRelation(ReasoningRelation relation)