Package com.semedy.reasoner.reasoning.processes

Class RuleCompiler

java.lang.Object

com.semedy.reasoner.reasoning.processes.RuleCompiler

public class RuleCompiler
extends Object

Constructor Summary

Constructors

Constructor	Description
RuleCompiler(InterruptFlag interruptflag, ReasoningMonitor monitor, SystemMonitor smonitor, IntensionalDB idb, Options options, SymbolTable symboltable, BuiltinProvider builtinFactory, ExtensionalDB[] sharedEDBs, boolean streamReasoning, boolean streamReasoningWithRetracts, SimpleSemaphore semaphorForSensors, String tempDir, boolean swapping, boolean skipAnswers, Properties builtinProperties)

Method Summary

Modifier and Type	Method	Description
void	attachReceiver(Receiver receiver, ExtensionalDB temporaryEDB)	attach a receiver to the ith query to process net which gets the results of the evaluation
void	attachReceiver(List<Receiver> receiver, ExtensionalDB temporaryEDB)	attach a receiver to process net which gets the results of the evaluation
void	attachToEDB()	attach process net to central edb
void	attachToEDB(ExtensionalDB[] edbs)	attach process net to edb
ProcessExecutor	compileRules()	compile all rules and create a process net
ProcessExecutor	compileRules(int[] partsVector)	compile all rules and create a process graph
static int[]	createPartsVector(IntensionalDB idb)	creates a vector of max parts for literals.
List<Rule>	getQueries()	get the final queries
ProcessExecutor	prepareCompilation()	preparation steps for compilation
void	pushProcesses()	initialize evaluation

Methods inherited from class java.lang.Object

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

Constructor Details

RuleCompiler

public RuleCompiler(InterruptFlag interruptflag,
 ReasoningMonitor monitor,
 SystemMonitor smonitor,
 IntensionalDB idb,
 Options options,
 SymbolTable symboltable,
 BuiltinProvider builtinFactory,
 ExtensionalDB[] sharedEDBs,
 boolean streamReasoning,
 boolean streamReasoningWithRetracts,
 SimpleSemaphore semaphorForSensors,
 String tempDir,
 boolean swapping,
 boolean skipAnswers,
 Properties builtinProperties)

Method Details

getQueries

public List<Rule> getQueries()

get the final queries

Returns:

createPartsVector

public static int[] createPartsVector(IntensionalDB idb)

creates a vector of max parts for literals. Used for partitioning of relations for parallel reasoneing

Returns:

attachReceiver

public void attachReceiver(List<Receiver> receiver,
 ExtensionalDB temporaryEDB)
                    throws ReasoningException,
IOException

attach a receiver to process net which gets the results of the evaluation

Parameters:

receiver -

temporaryEDB -

Throws:

ReasoningException

IOException

attachReceiver

public void attachReceiver(Receiver receiver,
 ExtensionalDB temporaryEDB)
                    throws ReasoningException,
IOException

attach a receiver to the ith query to process net which gets the results of the evaluation

Parameters:

receiver -

temporaryEDB -

Throws:

ReasoningException

IOException

attachToEDB

public void attachToEDB(ExtensionalDB[] edbs)
                 throws ReasoningException,
IOException,
EDBException

attach process net to edb

Parameters:

edbs -

Throws:

ReasoningException

IOException

EDBException

attachToEDB

public void attachToEDB()
                 throws ReasoningException,
IOException,
EDBException

attach process net to central edb

Throws:

ReasoningException

IOException

EDBException

ReasoningException

pushProcesses

public void pushProcesses()

initialize evaluation

prepareCompilation

public ProcessExecutor prepareCompilation()
                                   throws IOException,
SemReasonerException

preparation steps for compilation

Returns:

Throws:

IOException

SemReasonerException

compileRules

public ProcessExecutor compileRules()
                             throws IOException,
SemReasonerException

compile all rules and create a process net

Returns:

Throws:

IOException

SemReasonerException

compileRules

public ProcessExecutor compileRules(int[] partsVector)
                             throws IOException,
SemReasonerException

compile all rules and create a process graph

Returns:

Throws:

IOException

SemReasonerException