Package com.semedy.reasoner.reasoning.processes

Class And

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.And

All Implemented Interfaces:

Receiver, Process

Direct Known Subclasses:

ExecuteAggregation, ExecuteConnectorBuiltin, Not

public class And
extends ProcessImp

Constructor Summary

Constructors

Constructor	Description
And(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, VariableHandler vh, int[] externalFilterPositions, long[] externalFilterValues, RuleEvaluator reval, int part, int ofAllParts, boolean cepReasoning, com.semedy.reasoner.reasoning.processes.SystemMonitor.JoinType joinType, String queryKey)

Method Summary

Modifier and Type	Method	Description
void	evaluate()	evaluate a process during reasoning.
void	evaluationFinished()
void	evaluationFinished(long querykey)	the whole evaluation is finished
BufferedStore	getBottomStore()
Store	getLeftStore()
void	setBottomParameters(int[] destBottom)
void	setBottomStore(BufferedStore S)
void	setLeftFilter(int[] filterPositions, long[] filterValues)
void	setLeftParameters(int[] compareLeft, int[] leftSource, int[] leftDest, int[] filterPositions, long[] filterValues)
void	setLeftStore(Store S)
String	toString()
void	tuplesReceived(int ticket)
void	wakeUpMain()

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

And

public And(int i,
 InterruptFlag interruptFlag,
 ReasoningMonitor monitor,
 SystemMonitor smonitor,
 VariableHandler vh,
 int[] externalFilterPositions,
 long[] externalFilterValues,
 RuleEvaluator reval,
 int part,
 int ofAllParts,
 boolean cepReasoning,
 com.semedy.reasoner.reasoning.processes.SystemMonitor.JoinType joinType,
 String queryKey)

Method Details

wakeUpMain

public void wakeUpMain()

toString

public String toString()

Overrides:

toString in class Object

tuplesReceived

public void tuplesReceived(int ticket)

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

setLeftStore

public void setLeftStore(Store S)

getLeftStore

public Store getLeftStore()

setBottomStore

public void setBottomStore(BufferedStore S)

getBottomStore

public BufferedStore getBottomStore()

setBottomParameters

public void setBottomParameters(int[] destBottom)

setLeftParameters

public void setLeftParameters(int[] compareLeft,
 int[] leftSource,
 int[] leftDest,
 int[] filterPositions,
 long[] filterValues)

setLeftFilter

public void setLeftFilter(int[] filterPositions,
 long[] filterValues)

evaluationFinished

public void evaluationFinished()
                        throws ReasoningException,
IOException

Overrides:

evaluationFinished in class ProcessImp

Throws:

ReasoningException

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 ProcessImp

Throws:

ReasoningException

IOException