Package com.semedy.reasoner.api.reasoning

Interface Receiver

All Known Subinterfaces:

DirectFilterBuiltin, Process, Store, TopDownStore

All Known Implementing Classes:

And, BufferedStore, DirectBetween, DirectLess, DirectLessOrEqual, EmptyEventResultReceiver, EmptyStore, Encoder, End, EventReceiver, EventResultReceiver, ExecuteAggregation, ExecuteConnectorBuiltin, ExecuteDirectFilterBuiltin, ExecuteFilterBuiltin, ExecuteFunctionalBuiltin, ExecuteRelationalBuiltin, IntermediateResultProducer, IsNotFunctional2, IsNotFunctional3, Match, MaterializationReceiver, Not, ProcessImp, ResultReceiver, RuleEvaluator, Scatter, SetConstants, StoreEventResultReceiver, SubstituteFunction, SynchronizedBufferedStore, TestEqual, TopDown, TopDownBufferedStore, TopDownTrigger, TopDownUnbufferedStore, UnbufferedStore, VariableToVariable

public interface Receiver

A receiver collects tuples ad intermediate results during reasoning.

Author:

angele

Method Summary

Modifier and Type	Method	Description
void	addRelation(ReasoningRelation relation)	add a whole relation at the beginning
int	getArity()	arity of the tuples
TupleStore	getTupleStore()	get the basic tuple store
boolean	receiveRelation(ReasoningRelation relation)	receive a whole relation
boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
boolean	receiveTuple(TupleBuffer tuple)	receive a single tuple
Receiver	startTuples(Receiver source, boolean check4Duplicates)	start delivering single tuples
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples
void	tuplesFinished(String annotation, ReasoningRelation T1, ReasoningRelation T2)	Finish delivering single tuples.

Method Details

startTuples

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

start delivering single tuples

Parameters:

check4Duplicates - , check for duplicates in the target store

source - , the delivering process

Returns:

an object receiving the results

Throws:

IOException

EDBException

tuplesFinished

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

finish delivering single tuples

Parameters:

isBottomUp - TODO

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

tuplesFinished

void tuplesFinished(String annotation,
 ReasoningRelation T1,
 ReasoningRelation T2)
             throws InterruptedException,
IOException,
SemReasonerException

Finish delivering single tuples.
Cache result and annotate result.

Parameters:

annotation - , an annotation used for caching

T1 - , the relations which have been combined

T2 - , the relations which have been combined

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

addRelation

void addRelation(ReasoningRelation relation)
          throws IOException,
EDBException

add a whole relation at the beginning

Parameters:

relation - the relation to be added

Throws:

IOException

EDBException

getArity

int getArity()

arity of the tuples

Returns:

the arity of the receiver

getTupleStore

TupleStore getTupleStore()

get the basic tuple store

Returns:

the tuple store

receiveTuple

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

receive a single tuple

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

InterruptedException

IOException

receiveTuple

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

receive a single tuple

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

InterruptedException

IOException

SemReasonerException

receiveTuple

boolean receiveTuple(TupleBuffer tuple)
              throws InterruptedException,
IOException,
SemReasonerException

receive a single tuple

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

receiveRelation

boolean receiveRelation(ReasoningRelation relation)
                 throws SemReasonerException,
InterruptedException,
IOException

receive a whole relation

Parameters:

relation - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException