Package com.semedy.reasoner.reasoning.processes

Class ProcessImp

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

All Implemented Interfaces:

Receiver, Process

Direct Known Subclasses:

And, End, EventResultReceiver, ExecuteDirectFilterBuiltin, ExecuteFilterBuiltin, ExecuteFunctionalBuiltin, ExecuteRelationalBuiltin, Match, RuleEvaluator, Scatter, SetConstants, SubstituteFunction, TestEqual, TopDown, TopDownTrigger, UnbufferedStore, VariableToVariable

public abstract class ProcessImp
extends Object
implements Receiver, Process

Represents a process in the operator net.
The process executor executes the processes.
Every process has a priority it is executed with.
Processes wait in an evaluation queue for being executed.

Author:

angele

Constructor Summary

Constructors

Constructor	Description
ProcessImp(InterruptFlag interruptFlag, int arity, ReasoningMonitor monitor)
ProcessImp(InterruptFlag interruptFlag, ReasoningMonitor monitor)

Method Summary

Modifier and Type	Method	Description
void	addNextReceiver(Receiver n)	attach a next receiver which receives input from this
void	addRelation(ReasoningRelation tuples)	add a whole relation at the beginning
void	clear()	free up ressources
void	dispose()	free ressources allocated by this process
void	evaluate()	evaluate a process during reasoning.
void	evaluationFinished()
void	evaluationFinished(long querykey)	the whole evaluation is finished
int	getArity()	arity of the tuples
int	getPriority()	get the priority of a process
int	getStratum()	get the stratum
TupleStore	getTupleStore()	get the basic tuple store
boolean	isNotQueuedSetQueued()	If process is not queued for reasoning set it as queued for reasoning
final boolean	isQueued()	is process queued for reasoning
Receiver	nextReceiver()	get next process
void	operationFinished()	this process is finished
boolean	receiveRelation(ReasoningRelation tuples)	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
void	setDataFlowGraph(ProcessExecutor processExecutor)	set the executor for this process
final void	setQueued(boolean stacked)	mark process as queued for reasoning
void	setStratum(int s)	set the stratum of this process
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.

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessImp

public ProcessImp(InterruptFlag interruptFlag,
 ReasoningMonitor monitor)

ProcessImp

public ProcessImp(InterruptFlag interruptFlag,
 int arity,
 ReasoningMonitor monitor)

Method Details

getPriority

public int getPriority()

Description copied from interface: Process

get the priority of a process

Specified by:

getPriority in interface Process

Returns:

evaluate

public void evaluate()
              throws InterruptedException,
SemReasonerException,
IOException

Description copied from interface: Process

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

Specified by:

evaluate in interface Process

Throws:

InterruptedException

ReasoningException

IOException

SemReasonerException

clear

public void clear()
           throws IOException

free up ressources

Specified by:

clear in interface Process

Throws:

IOException

setQueued

public final void setQueued(boolean stacked)

Description copied from interface: Process

mark process as queued for reasoning

Specified by:

setQueued in interface Process

isQueued

public final boolean isQueued()

Description copied from interface: Process

is process queued for reasoning

Specified by:

isQueued in interface Process

Returns:

isNotQueuedSetQueued

public boolean isNotQueuedSetQueued()

Description copied from interface: Process

If process is not queued for reasoning set it as queued for reasoning

Specified by:

isNotQueuedSetQueued in interface Process

Returns:

setDataFlowGraph

public void setDataFlowGraph(ProcessExecutor processExecutor)

Description copied from interface: Process

set the executor for this process

Specified by:

setDataFlowGraph in interface Process

operationFinished

public void operationFinished()
                       throws SemReasonerException

Description copied from interface: Process

this process is finished

Specified by:

operationFinished in interface Process

Throws:

SemReasonerException

evaluationFinished

public void evaluationFinished(long querykey)
                        throws IOException,
SemReasonerException

Description copied from interface: Process

the whole evaluation is finished

Specified by:

evaluationFinished in interface Process

Throws:

ReasoningException

IOException

SemReasonerException

evaluationFinished

public void evaluationFinished()
                        throws IOException,
SemReasonerException

Throws:

IOException

SemReasonerException

startTuples

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

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

Throws:

IOException

EDBException

tuplesFinished

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

Description copied from interface: Receiver

finish delivering single tuples

Specified by:

tuplesFinished in interface Receiver

Parameters:

isBottomUp - TODO

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

tuplesFinished

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

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

T1 - , the relations which have been combined

T2 - , the relations which have been combined

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

addRelation

public void addRelation(ReasoningRelation tuples)
                 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

Parameters:

tuples - the relation to be added

Throws:

IOException

EDBException

getArity

public int getArity()

Description copied from interface: Receiver

arity of the tuples

Specified by:

getArity in interface Process

Specified by:

getArity in interface Receiver

Returns:

the arity of the receiver

addNextReceiver

public void addNextReceiver(Receiver n)

Description copied from interface: Process

attach a next receiver which receives input from this

Specified by:

addNextReceiver in interface Process

receiveRelation

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

Description copied from interface: Receiver

receive a whole relation

Specified by:

receiveRelation in interface Receiver

Parameters:

tuples - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

receiveTuple

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

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:

InterruptedException

IOException

SemReasonerException

receiveTuple

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

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:

InterruptedException

IOException

SemReasonerException

receiveTuple

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

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:

InterruptedException

IOException

ReasoningException

SemReasonerException

getTupleStore

public TupleStore getTupleStore()

Description copied from interface: Receiver

get the basic tuple store

Specified by:

getTupleStore in interface Process

Specified by:

getTupleStore in interface Receiver

Returns:

the tuple store

dispose

public void dispose()

Description copied from interface: Process

free ressources allocated by this process

Specified by:

dispose in interface Process

setStratum

public void setStratum(int s)

Description copied from interface: Process

set the stratum of this process

Specified by:

setStratum in interface Process

getStratum

public int getStratum()

Description copied from interface: Process

get the stratum

Specified by:

getStratum in interface Process

Returns:

nextReceiver

public Receiver nextReceiver()

Description copied from interface: Process

get next process

Specified by:

nextReceiver in interface Process

Returns: