Package com.semedy.reasoner.reasoning.processes

Interface Store

All Superinterfaces:

Process, Receiver

All Known Subinterfaces:

TopDownStore

All Known Implementing Classes:

BufferedStore, EmptyStore, SynchronizedBufferedStore, TopDownBufferedStore, TopDownUnbufferedStore, UnbufferedStore

public interface Store
extends Process

Author:

angele

Method Summary

Modifier and Type	Method	Description
void	addNegatedNeighbour(And join)	add a negated rule body operator as next operator
void	addNeighbour(And join)	add a rule body operator as next operator
void	addRelation(ReasoningRelation R)	add a relation (at the beginning)
void	evaluate()	evaluate the store
void	evaluationFinished(long querykey)	Evaluation for query with querykey is finished
List<ReasoningRelation>	getAllTuples()
ReasoningRelation	getAllTuplesInOne()	get all received tuples
int	getArity()	the arity of the tuples
ReasoningRelation	getLastResults()	get the last stores results
List<And>	getNeighbours()	get all neighbours
TupleStore	getTupleStore()	get the basic tuple stoe
List<ReasoningRelation>	incrementalRelations()
boolean	isSubsumed()	Store is subsumed.
void	readAccessBegin(Set<Integer> tickets, boolean lock)	Reading of the store by an operator starts.
boolean	readAccessEnd(ProcessImp source, Set<Integer> tickets, boolean lock, boolean pushed)	Reading of a store ends.
boolean	receiveRelation(ReasoningRelation R)	receive a whole relation with tuples
boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
List<ReasoningRelation>	relations()
long	size()
Receiver	startTuples(Receiver source, boolean check4Duplicates)	a process which delivers single tuples starts
String	toString()
void	triggerNeighbours(int ticket)	trigger neighbours for evaluation
void	tuplesFinished(boolean isBottomUp)	finish of delivery of single tuples
void	tuplesFinished(String annotation, ReasoningRelation R1, ReasoningRelation R2)	finish of delivery of single tuples

Methods inherited from interface com.semedy.reasoner.reasoning.processes.Process

addNextReceiver, clear, dispose, getPriority, getStratum, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, setDataFlowGraph, setQueued, setStratum

Methods inherited from interface com.semedy.reasoner.api.reasoning.Receiver

receiveTuple

Method Details

evaluationFinished

void evaluationFinished(long querykey)
                 throws SemReasonerException

Evaluation for query with querykey is finished

Specified by:

evaluationFinished in interface Process

Throws:

ReasoningException

SemReasonerException

size

long size()
   throws IOException,
EDBException

Returns:

Throws:

EDBException - How many tuples are stored

IOException

getAllTuples

List<ReasoningRelation> getAllTuples()
                              throws IOException,
EDBException

Returns:

Throws:

EDBException - get a list of all relations stored in store

IOException

getAllTuplesInOne

ReasoningRelation getAllTuplesInOne()
                             throws IOException,
SemReasonerException

get all received tuples

Returns:

Throws:

ReasoningException

IOException

SemReasonerException

addNegatedNeighbour

void addNegatedNeighbour(And join)

add a negated rule body operator as next operator

Parameters:

join -

addNeighbour

void addNeighbour(And join)

add a rule body operator as next operator

Parameters:

join -

readAccessBegin

void readAccessBegin(Set<Integer> tickets,
 boolean lock)

Reading of the store by an operator starts.
Every reading is uniquely identified by a ticket.
Lock indicates that ressources must be locked

Parameters:

tickets -

lock -

readAccessEnd

boolean readAccessEnd(ProcessImp source,
 Set<Integer> tickets,
 boolean lock,
 boolean pushed)
               throws IOException,
SemReasonerException

Reading of a store ends.

Parameters:

source - , the reader

tickets - , the ticket of the reading process

lock - , was a lock required at begin of the reading process

pushed - , have relations be pushed instead of joined

Returns:

Throws:

IOException

SemReasonerException

receiveRelation

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

receive a whole relation with tuples

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

IOException

SemReasonerException

addRelation

void addRelation(ReasoningRelation R)
          throws IOException,
EDBException

add a relation (at the beginning)

Specified by:

addRelation in interface Process

Specified by:

addRelation in interface Receiver

Parameters:

R - the relation to be added

Throws:

IOException

EDBException

startTuples

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

a process which delivers single tuples starts

Specified by:

startTuples in interface Receiver

Parameters:

source - , the process delivering the tuples

check4Duplicates - , eliminate duplicates

Returns:

an object receiving the results

Throws:

EDBException

IOException

incrementalRelations

List<ReasoningRelation> incrementalRelations()
                                      throws IOException,
EDBException

Returns:

Throws:

EDBException - get a list of incremental relations

IOException

relations

List<ReasoningRelation> relations()
                           throws IOException,
EDBException

Returns:

Throws:

EDBException - get a list of received relations

IOException

getArity

int getArity()

the arity of the tuples

Specified by:

getArity in interface Process

Specified by:

getArity in interface Receiver

Returns:

the arity of the receiver

isSubsumed

boolean isSubsumed()

Store is subsumed. This means that no additional tuples are stored.

Returns:

toString

String toString()

Overrides:

toString in class Object

receiveTuple

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

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Parameters:

tuple -

Returns:

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

Throws:

SemReasonerException

IOException

receiveTuple

boolean receiveTuple(int tuple)
              throws SemReasonerException,
IOException

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Parameters:

tuple -

Returns:

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

Throws:

SemReasonerException

IOException

getTupleStore

TupleStore getTupleStore()

get the basic tuple stoe

Specified by:

getTupleStore in interface Process

Specified by:

getTupleStore in interface Receiver

Returns:

the tuple store

evaluate

void evaluate()
       throws InterruptedException,
SemReasonerException,
IOException

evaluate the store

Specified by:

evaluate in interface Process

Throws:

InterruptedException

ReasoningException

IOException

SemReasonerException

tuplesFinished

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

finish of delivery of single tuples

Specified by:

tuplesFinished in interface Receiver

Parameters:

annotation -

R1 - ,

R2 -

Throws:

IOException

ReasoningException

SemReasonerException

InterruptedException

tuplesFinished

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

finish of delivery of single tuples

Specified by:

tuplesFinished in interface Receiver

Parameters:

isBottomUp - TODO

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException

triggerNeighbours

void triggerNeighbours(int ticket)
                throws SemReasonerException,
IOException

trigger neighbours for evaluation

Parameters:

ticket -

Throws:

IOException

ReasoningException

SemReasonerException

getNeighbours

List<And> getNeighbours()

get all neighbours

Returns:

getLastResults

ReasoningRelation getLastResults()

get the last stores results

Returns: