Package com.semedy.reasoner.reasoning

Class ReasonerNotThreaded

java.lang.Object

com.semedy.reasoner.reasoning.ReasonerNotThreaded

All Implemented Interfaces:

Reasoner

public class ReasonerNotThreaded
extends Object
implements Reasoner

Reasoner.
Reasoner selects rules according to queries,
rewrites the rules with the rewriters,
compiles rules into execution structure,
executes the rules,
and finally creates the answers

Author:

angele

Constructor Summary

Constructors

Constructor	Description
ReasonerNotThreaded(InterruptFlag interruptFlag, SymbolTable symboltable, BuiltinProvider builtinFactory, boolean skipAnswers, long maxNumberOfResults, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties)
ReasonerNotThreaded(InterruptFlag interruptFlag, SymbolTable symboltable, BuiltinProvider builtinFactory, ReasoningMonitor monitor, boolean skipAnswers, long maxNumberOfResults, SimpleSemaphore semaphorForSensors, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the reasoner.
void	compile(IntensionalDB idb, ExtensionalDB[] edbs, ReasoningMonitor monitor, SystemMonitor smonitor, boolean topdown, int[] partsVector, boolean cepReasoningWithRetracts, boolean cepReasoning)
void	compile(IntensionalDB idb, ExtensionalDB[] edbs, ReasoningMonitor monitor, SystemMonitor smonitor, boolean topdown, int maxNumberOfResults, boolean streamReasoning, boolean cepReasoningWithRetracts)	Compile rules to a data flow
List<TupleEnumerator>	evaluate()	Start evaluation and return an iterator for the results
void	evaluate(Receiver receiver)	Starts evaluation and feed the results into receiver
List<List<TupleEnumerator>>	evaluateSeveralQueries()	Starts evaluation for several queries.
void	evaluationFinished()	evaluation is finished
List<Rule>	getQueries()	get queries after compilation
SymbolTable	getSymbolTable()	Returns the reasoning symbol table used to create new symbols during reasoning
void	register(InterruptFlag interruptFlag, EventResultReceiver receiver, CoreReadLock edbReadLock)
void	register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock)	Register several queries for events caused by sensors or in case of stream reasoning db caused by added facts. Every time events from sensors arrive there might be one or more new results. For every result receiver.receive is called This is used for stream reasoning
boolean	resultsContainedEDBRelations()	Have results contained whole edb relations?
boolean	test(Reader in, SymbolTable baseTable, ExternalDataTypeProvider datatypes, ExtensionalDB edb, boolean topdown, String path, BuiltinProvider builtinProvider, RewriterProvider rewriterProvider, Configuration config, Properties prp)	testing the evaluation.

Methods inherited from class java.lang.Object

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

Constructor Details

ReasonerNotThreaded

public ReasonerNotThreaded(InterruptFlag interruptFlag,
 SymbolTable symboltable,
 BuiltinProvider builtinFactory,
 ReasoningMonitor monitor,
 boolean skipAnswers,
 long maxNumberOfResults,
 SimpleSemaphore semaphorForSensors,
 boolean cepReasoning,
 boolean cepReasoningWithRetracts,
 String tempDir,
 boolean swapping,
 Properties builtinProperties)

ReasonerNotThreaded

public ReasonerNotThreaded(InterruptFlag interruptFlag,
 SymbolTable symboltable,
 BuiltinProvider builtinFactory,
 boolean skipAnswers,
 long maxNumberOfResults,
 boolean cepReasoning,
 boolean cepReasoningWithRetracts,
 String tempDir,
 boolean swapping,
 Properties builtinProperties)

Method Details

test

public boolean test(Reader in,
 SymbolTable baseTable,
 ExternalDataTypeProvider datatypes,
 ExtensionalDB edb,
 boolean topdown,
 String path,
 BuiltinProvider builtinProvider,
 RewriterProvider rewriterProvider,
 Configuration config,
 Properties prp)
             throws IOException,
SemReasonerException,
InterruptedException

testing the evaluation. The file contains rules and facts and solutions.
Solutions are given by the solutions predicate. This method reads the file,
stores the facts in an edb, stores the rules in an idb, compiles and evaluates
the query and compares the results with the solutions

Specified by:

test in interface Reasoner

Parameters:

in -

baseTable -

datatypes -

topdown -

path -

builtinProvider -

rewriterProvider -

config -

edb - , extensional database

prp - , builtin properties

Returns:

Throws:

SemReasonerException

InterruptedException

IOException

ReasoningException

evaluate

public void evaluate(Receiver receiver)
              throws InterruptedException,
SemReasonerException,
IOException

Description copied from interface: Reasoner

Starts evaluation and feed the results into receiver

Specified by:

evaluate in interface Reasoner

Parameters:

receiver -

Throws:

IOException - evaluate the current data flow and send results to receiver

InterruptedException - @throws TransactionException @throws

ReasoningException

SemReasonerException

evaluate

public List<TupleEnumerator> evaluate()
                               throws InterruptedException,
SemReasonerException,
IOException

Start evaluation and return an iterator for the results

Specified by:

evaluate in interface Reasoner

Returns:

Throws:

TransactionException

InterruptedException

SemReasonerException

IOException

ReasoningException

close

public void close()

Close the reasoner. Must be called to correctly finalize the reasoner

Specified by:

close in interface Reasoner

evaluationFinished

public void evaluationFinished()
                        throws SemReasonerException,
IOException,
InterruptedException

evaluation is finished

Specified by:

evaluationFinished in interface Reasoner

Throws:

ReasoningException

SemReasonerException

IOException

InterruptedException

getSymbolTable

public SymbolTable getSymbolTable()

Returns the reasoning symbol table used to create new symbols during reasoning

Specified by:

getSymbolTable in interface Reasoner

Returns:

compile

public void compile(IntensionalDB idb,
 ExtensionalDB[] edbs,
 ReasoningMonitor monitor,
 SystemMonitor smonitor,
 boolean topdown,
 int maxNumberOfResults,
 boolean streamReasoning,
 boolean cepReasoningWithRetracts)
             throws InterruptedException,
SemReasonerException,
IOException

Compile rules to a data flow

Specified by:

compile in interface Reasoner

Parameters:

idb - , intensional db

edbs - extensional dbs

monitor - reasoning monitor

smonitor - system monitor

topdown - execution is done top down

maxNumberOfResults - , max number of results

streamReasoning - , enable stream reasoning

cepReasoningWithRetracts - , allow retracts for stream reasoning

Throws:

InterruptedException

IOException

SemReasonerException

compile

public void compile(IntensionalDB idb,
 ExtensionalDB[] edbs,
 ReasoningMonitor monitor,
 SystemMonitor smonitor,
 boolean topdown,
 int[] partsVector,
 boolean cepReasoningWithRetracts,
 boolean cepReasoning)
             throws SemReasonerException,
IOException

Throws:

SemReasonerException

IOException

evaluateSeveralQueries

public List<List<TupleEnumerator>> evaluateSeveralQueries()
                                                   throws InterruptedException,
SemReasonerException,
IOException

Description copied from interface: Reasoner

Starts evaluation for several queries.
For every query a list of iterators for the results is returned.

Specified by:

evaluateSeveralQueries in interface Reasoner

Returns:

, list of tuple enumerators for results

Throws:

InterruptedException

ReasoningException

SemReasonerException

IOException

register

public void register(InterruptFlag interruptFlag,
 EventResultReceiver receiver,
 CoreReadLock edbReadLock)
              throws InterruptedException,
SemReasonerException,
IOException

Parameters:

receiver -

Throws:

IOException - evaluate the current data flow and send results to receiver

InterruptedException - @throws TransactionException @throws

SemReasonerException

register

public void register(InterruptFlag interruptFlag,
 List<EventResultReceiver> receiver,
 CoreReadLock edbReadLock)
              throws InterruptedException,
SemReasonerException,
IOException

Description copied from interface: Reasoner

Register several queries for events caused by sensors or in case of
stream reasoning db caused by added facts.
Every time events from sensors arrive there might be one or more new results.
For every result receiver.receive is called
This is used for stream reasoning

Specified by:

register in interface Reasoner

Parameters:

interruptFlag - , interrupt

edbReadLock - , the read lock for the extensional db, used during reasoning

Throws:

SemReasonerException

IOException

InterruptedException

resultsContainedEDBRelations

public boolean resultsContainedEDBRelations()

Description copied from interface: Reasoner

Have results contained whole edb relations?

Specified by:

resultsContainedEDBRelations in interface Reasoner

Returns:

getQueries

public List<Rule> getQueries()

Description copied from interface: Reasoner

get queries after compilation

Specified by:

getQueries in interface Reasoner

Returns: