Package com.semedy.reasoner.reasoning.processes

Class ExecuteAggregation

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.And

com.semedy.reasoner.reasoning.processes.ExecuteAggregation

All Implemented Interfaces:

Receiver, Deferred, Process

public class ExecuteAggregation
extends And
implements Deferred

Constructor Summary

Constructors

Constructor	Description
ExecuteAggregation(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, VariableHandler vh, int[] externalFilterPositions, long[] externalFilterValues, Aggregation aggregation, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning, String query)

Method Summary

Modifier and Type	Method	Description
void	clear()	free up ressources
void	deferredEvaluate()
void	evaluate()	evaluate a process during reasoning.
void	evaluationFinished(long querykey)	the whole evaluation is finished
boolean	hasBeenExecuted()
void	tuplesFinished(String annotation, ReasoningRelation T1, ReasoningRelation T2)	Finish delivering single tuples.
void	tuplesReceived(int ticket)

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

evaluationFinished, getBottomStore, getLeftStore, setBottomParameters, setBottomStore, setLeftFilter, setLeftParameters, setLeftStore, toString, wakeUpMain

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

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

Methods inherited from class java.lang.Object

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

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

getStratum, setStratum

Constructor Details

ExecuteAggregation

public ExecuteAggregation(int i,
 InterruptFlag interruptFlag,
 ReasoningMonitor monitor,
 SystemMonitor smonitor,
 VariableHandler vh,
 int[] externalFilterPositions,
 long[] externalFilterValues,
 Aggregation aggregation,
 SymbolTable symboltable,
 RuleEvaluator reval,
 boolean cepReasoning,
 String query)

Method Details

hasBeenExecuted

public boolean hasBeenExecuted()

Specified by:

hasBeenExecuted in interface Deferred

deferredEvaluate

public void deferredEvaluate()
                      throws InterruptedException,
SemReasonerException,
IOException

Specified by:

deferredEvaluate in interface Deferred

Throws:

InterruptedException

SemReasonerException

IOException

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 And

Throws:

ReasoningException

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 And

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

tuplesReceived

public void tuplesReceived(int ticket)

Overrides:

tuplesReceived in class And

clear

public void clear()

Description copied from class: ProcessImp

free up ressources

Specified by:

clear in interface Process

Overrides:

clear in class ProcessImp