Package com.semedy.reasoner.reasoning.processes

Class ExecuteFunctionalBuiltin

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.ExecuteFunctionalBuiltin

All Implemented Interfaces:

Receiver, Process

public class ExecuteFunctionalBuiltin
extends ProcessImp

Constructor Summary

Constructors

Constructor	Description
ExecuteFunctionalBuiltin(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, VariableHandler vh, FunctionalBuiltin builtin, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning, boolean notinternalize)

Method Summary

Modifier and Type	Method	Description
void	evaluate()	evaluate a process during reasoning.
void	evaluationFinished(long querykey)	the whole evaluation is finished
TupleStore	getTupleStore()	return the local tuple store
void	push()
boolean	receiveRelation(ReasoningRelation relation)	receive a whole relation
boolean	receiveTuple(int tuple)	receive a single tuple
boolean	receiveTuple(long[] tuple)	receive a single tuple
void	tuplesFinished(String annotation, ReasoningRelation T1, ReasoningRelation T2)	Finish delivering single tuples.

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

addNextReceiver, addRelation, clear, dispose, evaluationFinished, getArity, getPriority, getStratum, isNotQueuedSetQueued, isQueued, nextReceiver, operationFinished, receiveTuple, setDataFlowGraph, setQueued, setStratum, startTuples, tuplesFinished

Methods inherited from class java.lang.Object

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

Constructor Details

ExecuteFunctionalBuiltin

public ExecuteFunctionalBuiltin(int i,
 InterruptFlag interruptFlag,
 ReasoningMonitor monitor,
 VariableHandler vh,
 FunctionalBuiltin builtin,
 SymbolTable symboltable,
 RuleEvaluator reval,
 boolean cepReasoning,
 boolean notinternalize)
                         throws BuiltinException

Parameters:

interruptFlag -

i -

interruptFlag -

monitor -

vh -

builtin -

symboltable -

reval -

cepReasoning -

notinternalize -

Throws:

BuiltinException

Method Details

evaluationFinished

public void evaluationFinished(long querykey)
                        throws IOException,
ReasoningException

Description copied from interface: Process

the whole evaluation is finished

Specified by:

evaluationFinished in interface Process

Overrides:

evaluationFinished in class ProcessImp

Throws:

ReasoningException

IOException

getTupleStore

public TupleStore getTupleStore()

return the local tuple store

Specified by:

getTupleStore in interface Process

Specified by:

getTupleStore in interface Receiver

Overrides:

getTupleStore in class ProcessImp

Returns:

the tuple store

receiveTuple

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

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

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

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

Description copied from interface: Receiver

receive a single tuple

Specified by:

receiveTuple in interface Receiver

Overrides:

receiveTuple in class ProcessImp

Parameters:

tuple - the tuple to be received

Returns:

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

Throws:

SemReasonerException

InterruptedException

IOException

receiveRelation

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

Description copied from interface: Receiver

receive a whole relation

Specified by:

receiveRelation in interface Receiver

Overrides:

receiveRelation in class ProcessImp

Parameters:

relation - the whole relation to be received

Returns:

true, if relation is later on dissolved, false otherwise

Throws:

ReasoningException

InterruptedException

IOException

SemReasonerException

push

public void push()
          throws SemReasonerException,
InterruptedException,
IOException

Throws:

SemReasonerException

InterruptedException

IOException

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

Overrides:

evaluate in class ProcessImp

Throws:

InterruptedException

ReasoningException

IOException

SemReasonerException

tuplesFinished

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

Description copied from interface: Receiver

Finish delivering single tuples.
Cache result and annotate result.

Specified by:

tuplesFinished in interface Receiver

Overrides:

tuplesFinished in class ProcessImp

Parameters:

annotation - , an annotation used for caching

T1 - , the relations which have been combined

T2 - , the relations which have been combined

Throws:

ReasoningException

SemReasonerException

InterruptedException

IOException