Package com.semedy.reasoner.reasoning.processes

Class SynchronizedBufferedStore

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.UnbufferedStore

com.semedy.reasoner.reasoning.processes.BufferedStore

com.semedy.reasoner.reasoning.processes.SynchronizedBufferedStore

All Implemented Interfaces:

Receiver, Process, Store

public class SynchronizedBufferedStore
extends BufferedStore

Stores intermediate results: results between two rule bodies or results of rule evaluations
For recursive rules or recursion cycles results must be buffered.
Performs duplicate elimination if necessary
Synchronized version used for sensor builtins

Author:

angele

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addRelation(ReasoningRelation R)	add a whole relation at the beginning
void	evaluate()	evaluate a process during reasoning.
void	readAccessBegin(Set<Integer> tickets, boolean lockit)	Reading of the store by an operator starts.
boolean	readAccessEnd(ProcessImp source, Set<Integer> tickets, boolean unlockit, boolean pushed)	Reading of a store ends.
boolean	receiveRelation(ReasoningRelation R)	receive a whole relation
Receiver	startTuples(Receiver source, boolean check4Duplicates)	start delivering single tuples
void	triggerNeighbours(int ticket)	trigger neighbours for evaluation
void	tuplesFinished(boolean isBottomUp)	finish delivering single tuples
void	tuplesFinished(String annotation, ReasoningRelation R1, ReasoningRelation R2)	Finish delivering single tuples.

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

addNegatedNeighbour, addNeighbour, bufferedSize, clear, evaluationFinished, getAllTuples, getAllTuplesInOne, getLastResults, getNeighbours, getTupleStore, isSubsumed, receiveTuple, receiveTuple, receiveTuple, reset1, size

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

getArity, incrementalRelations, incrementalSize, relations, toString

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

addNextReceiver, dispose, evaluationFinished, getPriority, getStratum, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, 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, dispose, getPriority, getStratum, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, setDataFlowGraph, setQueued, setStratum

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

getArity, incrementalRelations, relations, toString

Constructor Details

SynchronizedBufferedStore

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

Method Details

readAccessBegin

public void readAccessBegin(Set<Integer> tickets,
 boolean lockit)

Description copied from interface: Store

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

Specified by:

readAccessBegin in interface Store

Overrides:

readAccessBegin in class BufferedStore

readAccessEnd

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

Description copied from interface: Store

Reading of a store ends.

Specified by:

readAccessEnd in interface Store

Overrides:

readAccessEnd in class BufferedStore

Parameters:

source - , the reader

tickets - , the ticket of the reading process

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

pushed - , have relations be pushed instead of joined

Returns:

Throws:

SemReasonerException

IOException

receiveRelation

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

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 BufferedStore

Parameters:

R - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

addRelation

public void addRelation(ReasoningRelation R)
                 throws IOException,
EDBException

Description copied from interface: Receiver

add a whole relation at the beginning

Specified by:

addRelation in interface Process

Specified by:

addRelation in interface Receiver

Specified by:

addRelation in interface Store

Overrides:

addRelation in class BufferedStore

Parameters:

R - the relation to be added

Throws:

IOException

EDBException

triggerNeighbours

public void triggerNeighbours(int ticket)

Description copied from interface: Store

trigger neighbours for evaluation

Specified by:

triggerNeighbours in interface Store

Overrides:

triggerNeighbours in class BufferedStore

startTuples

public Receiver startTuples(Receiver source,
 boolean check4Duplicates)

Description copied from interface: Receiver

start delivering single tuples

Specified by:

startTuples in interface Receiver

Specified by:

startTuples in interface Store

Overrides:

startTuples in class UnbufferedStore

Parameters:

source - , the delivering process

check4Duplicates - , check for duplicates in the target store

Returns:

an object receiving the results

evaluate

public void evaluate()
              throws InterruptedException,
IOException,
SemReasonerException

Description copied from interface: Process

evaluate a process during reasoning.
Returns how the number of tuples sent away

Specified by:

evaluate in interface Process

Specified by:

evaluate in interface Store

Overrides:

evaluate in class BufferedStore

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

tuplesFinished

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

Description copied from interface: Receiver

Finish delivering single tuples.
Cache result and annotate result.

Specified by:

tuplesFinished in interface Receiver

Specified by:

tuplesFinished in interface Store

Overrides:

tuplesFinished in class BufferedStore

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

IOException

tuplesFinished

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

Description copied from interface: Receiver

finish delivering single tuples

Specified by:

tuplesFinished in interface Receiver

Specified by:

tuplesFinished in interface Store

Overrides:

tuplesFinished in class BufferedStore

Parameters:

isBottomUp - TODO

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException