Package com.semedy.reasoner.reasoning.processes

Class RuleEvaluator

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessImp

com.semedy.reasoner.reasoning.processes.RuleEvaluator

All Implemented Interfaces:

Receiver, Deferred, Process

public class RuleEvaluator
extends ProcessImp
implements Deferred

Constructor Summary

Constructors

Constructor	Description
RuleEvaluator(InterruptFlag interruptFlag, ReasoningMonitor monitor, Rule rule, Rule originalRule, Literal[] originalBodies, boolean extensional, boolean streamReasoning, ProcessExecutor pE, Schemas schemas)

Method Summary

Modifier and Type	Method	Description
void	deferredEvaluate()
void	evaluate()	evaluate a process during reasoning.
void	evaluateInternal()
void	evaluateThreaded()
Rule	getRule()
boolean	hasBeenExecuted()
boolean	isFinished()
void	setOperator(Process p, int index)	set the body operator for body literal at index
String	toString()
void	tuplesReceived(int bodyIndex)

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

addNextReceiver, addRelation, clear, dispose, evaluationFinished, evaluationFinished, 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

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

getStratum, setStratum

Constructor Details

RuleEvaluator

public RuleEvaluator(InterruptFlag interruptFlag,
 ReasoningMonitor monitor,
 Rule rule,
 Rule originalRule,
 Literal[] originalBodies,
 boolean extensional,
 boolean streamReasoning,
 ProcessExecutor pE,
 Schemas schemas)

Method Details

getRule

public Rule getRule()

isFinished

public boolean isFinished()

deferredEvaluate

public void deferredEvaluate()
                      throws InterruptedException,
IOException,
SemReasonerException

Specified by:

deferredEvaluate in interface Deferred

Throws:

InterruptedException

IOException

SemReasonerException

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

Overrides:

evaluate in class ProcessImp

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

evaluateInternal

public void evaluateInternal()
                      throws InterruptedException,
IOException,
SemReasonerException

Throws:

InterruptedException

IOException

SemReasonerException

evaluateThreaded

public void evaluateThreaded()
                      throws InterruptedException,
IOException,
SemReasonerException

Throws:

InterruptedException

IOException

SemReasonerException

tuplesReceived

public void tuplesReceived(int bodyIndex)

toString

public String toString()

Overrides:

toString in class Object

setOperator

public void setOperator(Process p,
 int index)

set the body operator for body literal at index

Parameters:

p -

index -

hasBeenExecuted

public boolean hasBeenExecuted()

Specified by:

hasBeenExecuted in interface Deferred