Package com.semedy.reasoner.reasoning.processes

Class TopDownUnbufferedStore

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.UnbufferedStore

com.semedy.reasoner.reasoning.processes.TopDownUnbufferedStore

All Implemented Interfaces:

Receiver, Process, Store, TopDownStore

public class TopDownUnbufferedStore
extends UnbufferedStore
implements TopDownStore

Constructor Summary

Constructors

Constructor	Description
TopDownUnbufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean not, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)

Method Summary

Modifier and Type	Method	Description
void	addBottomNeighbour(Receiver op)
List<Receiver>	getBottomNeighbours()
boolean	receiveRelation(ReasoningRelation R)	receive a whole relation
boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
void	triggerNeighbours(int ticket)	trigger neighbours for evaluation

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

addNegatedNeighbour, addNeighbour, addRelation, clear, evaluate, evaluationFinished, getAllTuples, getAllTuplesInOne, getArity, getLastResults, getNeighbours, getTupleStore, incrementalRelations, incrementalSize, isSubsumed, readAccessBegin, readAccessEnd, relations, size, startTuples, toString, tuplesFinished, tuplesFinished

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

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

Methods inherited from class java.lang.Object

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

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

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

addNegatedNeighbour, addNeighbour, addRelation, evaluate, evaluationFinished, getAllTuples, getAllTuplesInOne, getArity, getLastResults, getNeighbours, getTupleStore, incrementalRelations, isSubsumed, readAccessBegin, readAccessEnd, relations, size, startTuples, toString, tuplesFinished, tuplesFinished

Constructor Details

TopDownUnbufferedStore

public TopDownUnbufferedStore(InterruptFlag interruptFlag,
 ReasoningMonitor monitor,
 int arity,
 String predicate,
 boolean not,
 boolean cepReasoning,
 boolean cepReasoningWithRetracts,
 String tempDir,
 boolean swapping,
 ProcessExecutor executor,
 boolean sorted)
                       throws IOException

Parameters:

interruptFlag -

monitor -

arity -

predicate -

not -

cepReasoning -

cepReasoningWithRetracts -

tempDir -

swapping -

executor -

sorted -

Throws:

IOException

Method Details

addBottomNeighbour

public void addBottomNeighbour(Receiver op)

Specified by:

addBottomNeighbour in interface TopDownStore

triggerNeighbours

public void triggerNeighbours(int ticket)
                       throws SemReasonerException,
IOException

Description copied from interface: Store

trigger neighbours for evaluation

Specified by:

triggerNeighbours in interface Store

Overrides:

triggerNeighbours in class UnbufferedStore

Throws:

ReasoningException

IOException

SemReasonerException

receiveTuple

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

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Specified by:

receiveTuple in interface Store

Overrides:

receiveTuple in class UnbufferedStore

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

IOException

receiveTuple

public boolean receiveTuple(int tuple)
                     throws SemReasonerException,
IOException

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Specified by:

receiveTuple in interface Store

Overrides:

receiveTuple in class UnbufferedStore

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

IOException

receiveRelation

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

Description copied from interface: Receiver

receive a whole relation

Specified by:

receiveRelation in interface Receiver

Specified by:

receiveRelation in interface Store

Overrides:

receiveRelation in class UnbufferedStore

Parameters:

R - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

getBottomNeighbours

public List<Receiver> getBottomNeighbours()

Specified by:

getBottomNeighbours in interface TopDownStore