Package com.semedy.reasoner.reasoning

Class ReasonerThreadedRulesPartitioning

java.lang.Object

com.semedy.reasoner.reasoning.ReasonerThreadedRulesPartitioning

All Implemented Interfaces:

Reasoner

public class ReasonerThreadedRulesPartitioning
extends Object
implements Reasoner

Threaded reasoner

Author:

angele

Constructor Summary

Constructors

Constructor	Description
ReasonerThreadedRulesPartitioning(InterruptFlag interruptFlag, SymbolTable symboltable, BuiltinProvider builtinFactory, int reasoningthreads, boolean skipAnswers, int maxNumberOfResults, ReasoningMonitor monitor, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties, int pulsedTuples, boolean sorted)

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 maxNumberOfResults, boolean cepReasoningWithRetracts, boolean cepReasoning)	compile rules for the reasoning process
List<TupleEnumerator>	evaluate()	starts evaluation and returns iterators for the results of the evaluation
List<TupleEnumerator>	evaluate(ReasoningMonitor monitor)
void	evaluate(Receiver receiver)	Starts evaluation and feed the results into receiver
List<List<TupleEnumerator>>	evaluateSeveralQueries()	Starts evaluation for several queries.
void	evaluationFinished()	Is called after reasoning process is finished
List<Rule>	getQueries()	get queries after compilation
SymbolTable	getSymbolTable()	Returns the reasoning symbol table used to create new symbols during reasoning This reasoning symbol table is different to the base symbol table given by core.getSymbolTable() To decode reasoning results always use this one
void	register(EventResultReceiver receiver)
void	register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver)
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
void	register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock, SimpleSemaphore semaphore)
void	register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, SimpleSemaphore semaphore)
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

ReasonerThreadedRulesPartitioning

public ReasonerThreadedRulesPartitioning(InterruptFlag interruptFlag,
 SymbolTable symboltable,
 BuiltinProvider builtinFactory,
 int reasoningthreads,
 boolean skipAnswers,
 int maxNumberOfResults,
 ReasoningMonitor monitor,
 boolean cepReasoning,
 boolean cepReasoningWithRetracts,
 String tempDir,
 boolean swapping,
 Properties builtinProperties,
 int pulsedTuples,
 boolean sorted)

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 ReasoningException

Description copied from interface: Reasoner

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 to the solutions

Specified by:

test in interface Reasoner

Parameters:

in - , reader for e.g. a file

baseTable - , symbol table

edb - , extensional database

topdown - , top down evaluation (magic sets)

path - , path to edb

builtinProvider - , provides builtins

rewriterProvider - , provides rewriters

config - , a configuration

prp - , builtin properties

Returns:

true, if results of evaluation are the same as the solutions inside the file

Throws:

ReasoningException

evaluate

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

Throws:

InterruptedException

IOException

SemReasonerException

evaluate

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

Description copied from interface: Reasoner

Starts evaluation and feed the results into receiver

Specified by:

evaluate in interface Reasoner

Parameters:

receiver - , the results are sent to receiver

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

evaluate

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

Description copied from interface: Reasoner

starts evaluation and returns iterators for the results of the evaluation

Specified by:

evaluate in interface Reasoner

Returns:

iterator for results

Throws:

InterruptedException

IOException

ReasoningException

SemReasonerException

close

public void close()
           throws ReasoningException,
InterruptedException

Description copied from interface: Reasoner

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

Specified by:

close in interface Reasoner

Throws:

ReasoningException

InterruptedException

getSymbolTable

public SymbolTable getSymbolTable()

Description copied from interface: Reasoner

Returns the reasoning symbol table used to create new symbols during reasoning
This reasoning symbol table is different to the base symbol table given by core.getSymbolTable()
To decode reasoning results always use this one

Specified by:

getSymbolTable in interface Reasoner

Returns:

compile

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

Description copied from interface: Reasoner

compile rules for the reasoning process

Specified by:

compile in interface Reasoner

Parameters:

idb - , intensional db

edbs - extensional dbs

monitor - , monitoring reasoning and memory consumption

smonitor - , system monitor, used by system may be null

topdown - , execution is done top down (magic sets)

cepReasoningWithRetracts - , stream reasoning is done

cepReasoning - , retracts in stream reasoning

Throws:

InterruptedException

IOException

SemReasonerException

register

public void register(EventResultReceiver receiver)

evaluateSeveralQueries

public List<List<TupleEnumerator>> evaluateSeveralQueries()
                                                   throws InterruptedException,
ReasoningException

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

register

public void register(InterruptFlag interruptFlag,
 List<EventResultReceiver> receiver)

register

public void register(InterruptFlag interruptFlag,
 List<EventResultReceiver> receiver,
 SimpleSemaphore semaphore)

register

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

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:

InterruptedException

ReasoningException

register

public void register(InterruptFlag interruptFlag,
 List<EventResultReceiver> receiver,
 CoreReadLock edbReadLock,
 SimpleSemaphore semaphore)

evaluationFinished

public void evaluationFinished()
                        throws ReasoningException,
IOException

Description copied from interface: Reasoner

Is called after reasoning process is finished

Specified by:

evaluationFinished in interface Reasoner

Throws:

ReasoningException

IOException

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: