Uses of Class
com.semedy.reasoner.api.reasoning.InterruptFlag

Packages that use InterruptFlag

Package	Description
com.semedy.reasoner.api.core
com.semedy.reasoner.api.edb
com.semedy.reasoner.api.reasoning
com.semedy.reasoner.app
com.semedy.reasoner.core
com.semedy.reasoner.reasoning
com.semedy.reasoner.reasoning.processes

Uses of InterruptFlag in com.semedy.reasoner.api.core

Methods in com.semedy.reasoner.api.core with parameters of type InterruptFlag

Modifier and Type	Method	Description
Reasoner	Core.createReasoner(InterruptFlag interruptflag, boolean skipsendinganswers, int pulsedTuples)	creates a new resoner
Reasoner	Core.createReasoner(InterruptFlag interruptflag, boolean skipsendinganswers, int pulsedTuples, Properties builtinConfig)	creates a new resoner
void	DeductiveDatabase.export(InterruptFlag interrupt, List<String> predicates, String resultdirectory)	bulk export of facts for predicates to raw files in result directory
void	DeductiveDatabase.exportOOLogic(InterruptFlag interrupt, Writer writer, String module)	export of facts and rules for predicates to file in OO-logic into a module.
void	DeductiveDatabase.exportOOLogic(InterruptFlag interrupt, String resultpath, String module)	export of facts and rules for predicates to file in OO-logic into a module.
void	DeductiveDatabase.exportOOLogic(InterruptFlag interrupt, List<Filter> filters, Writer writer, String module)	export of facts and rules for predicates to file in OO-logic into a module.
void	DeductiveDatabase.exportOOLogic(InterruptFlag interrupt, List<Filter> filter, String resultpath, String module)	export of facts and rules for predicates to file in OO-logic into a module.
void	DeductiveDatabase.materializeQueries(InterruptFlag interruptFlag, String squeries, ReasoningMonitor monitor)	Materialize queries.
void	DeductiveDatabase.materializeQueries(InterruptFlag interruptFlag, String squeries, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Materialize queries.
void	DeductiveDatabase.materializeQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor)	Materialize queries.
void	DeductiveDatabase.materializeQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Materialize queries.
void	StreamReasoningDB.materializeQueries(InterruptFlag interruptFlag, String squeries, ReasoningMonitor monitor)	Materialize queries.
void	StreamReasoningDB.materializeQueries(InterruptFlag interruptFlag, String squeries, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Materialize queries.
void	StreamReasoningDB.materializeQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor)	Materialize queries.
void	StreamReasoningDB.materializeQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Materialize queries.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, Rule query, int maxNumberOfResults, ReasoningMonitor monitor)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, Rule query, int maxNumberOfResults, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, String query, int maxNumberOfResults, Configuration config, Properties builtinConfig)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, String query, int maxNumberOfResults, ReasoningMonitor monitor)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, String query, int maxNumberOfResults, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, String query, Properties builtinConfig)	Pose a query.
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, List<Rule> queries, int maxNumberOfResults, ReasoningMonitor monitor)	Pose a query and several rules
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, List<Rule> queries, int maxNumberOfResults, ReasoningMonitor monitor, Configuration config, Properties builtinConfig)	Pose a query and several rules
ResultEnumerator	DeductiveDatabase.query(InterruptFlag interruptFlag, List<Rule> queries, int maxNumberOfResults, ReasoningMonitor monitor, ExtensionalDB[] additionalEDBs, IntensionalDB[] additionalIDBs, boolean skipAnswers, Configuration config, Properties builtinConfig)	Pose a query and several rules.
void	StreamReasoningDB.registerQueries(InterruptFlag interruptFlag, String queries, ReasoningMonitor monitor, List<EventResultReceiver> receiver)	Register a set of queries for stream reasoning.
void	StreamReasoningDB.registerQueries(InterruptFlag interruptFlag, String queries, ReasoningMonitor monitor, List<EventResultReceiver> receiver, Properties builtinConfig)	Register a set of queries for stream reasoning.
void	StreamReasoningDB.registerQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor, List<EventResultReceiver> receiver)	Register a set of queries for stream reasoning.
void	StreamReasoningDB.registerQueries(InterruptFlag interruptFlag, List<Rule> queries, ReasoningMonitor monitor, List<EventResultReceiver> receiver, Properties builtinConfig)	Register a set of queries for stream reasoning.

Constructors in com.semedy.reasoner.api.core with parameters of type InterruptFlag

Modifier	Constructor	Description
	EventResultReceiver(InterruptFlag interruptFlag, int arity, ReasoningMonitor monitor)
	EventResultReceiver(InterruptFlag interruptFlag, ReasoningMonitor monitor)
	MaterializationReceiver(InterruptFlag interruptFlag, Literal literal, DeductiveDatabase ddb, ExtensionalDB edb, SymbolTable symbols, SymbolTable reasoningSymbols)
	StoreEventResultReceiver(InterruptFlag interruptFlag, DeductiveDatabase ddb, String predicateSymbol, int arity, String tempDir, String edbDir, boolean isPersistent, boolean writeLock, ReasoningMonitor monitor)

Uses of InterruptFlag in com.semedy.reasoner.api.edb

Methods in com.semedy.reasoner.api.edb with parameters of type InterruptFlag

Modifier and Type	Method	Description
void	ExtensionalDB.bulkExport(InterruptFlag interrupt, List<Filter> filters, String resultdirectory, SymbolTable symbolTable)	Bulk export of facts for predicate symbols to raw files in result directory
void	ExtensionalDB.exportOOLogic(InterruptFlag interrupt, List<Filter> filters, Writer writer, SymbolTable symbolTable)	export of facts for predicate symbols to OO-logic file
void	ExtensionalDB.exportOOLogic(InterruptFlag interrupt, List<Filter> filters, Writer writer, SymbolTable symbolTable, String module)	export of facts for predicate symbols to OO-logic file.
void	ExtensionalDB.exportOOLogic(InterruptFlag interrupt, List<Filter> filters, String resultFile, SymbolTable symbolTable)	export of facts for predicate symbols to OO-logic file
void	ExtensionalDB.exportOOLogic(InterruptFlag interrupt, List<Filter> filters, String resultFile, SymbolTable symbolTable, String module)	export of facts for predicate symbols to OO-logic file.

Uses of InterruptFlag in com.semedy.reasoner.api.reasoning

Methods in com.semedy.reasoner.api.reasoning with parameters of type InterruptFlag

Modifier and Type	Method	Description
void	Reasoner.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

Constructors in com.semedy.reasoner.api.reasoning with parameters of type InterruptFlag

Modifier	Constructor	Description
	InterruptFlagListener(InterruptFlag interruptFlag)

Uses of InterruptFlag in com.semedy.reasoner.app

Methods in com.semedy.reasoner.app with parameters of type InterruptFlag

Modifier and Type	Method	Description
ResultEnumerator	QueryRunner.eval(InterruptFlag interruptflag, String flogic, String query, ReasoningMonitor monitor)
static void	QueryRegister.query(InterruptFlag interruptflag, String querypath, PrintStream out)
static void	QueryRunner.query(InterruptFlag interrupt, String querypath, PrintStream out)
void	QueryRegister.register(InterruptFlag interruptFlag, String flogic, String query, ReasoningMonitor monitor, PrintStream out)

Uses of InterruptFlag in com.semedy.reasoner.core

Methods in com.semedy.reasoner.core with parameters of type InterruptFlag

Modifier and Type	Method	Description
void	TransactionManager.transactionBegin(InterruptFlag interruptflag, Transaction transaction)	start a transaction in for a query

Constructors in com.semedy.reasoner.core with parameters of type InterruptFlag

Modifier	Constructor	Description
	EmptyEventResultReceiver(InterruptFlag interruptFlag, ReasoningMonitor monitor)
	IntermediateResultConsumer(InterruptFlag interrupt, BlockingQueue<Long> source, BlockingQueue<Object> target, int arity, SymbolTable symbols)
	IntermediateResultProducer(InterruptFlag interruptflag, int arity, String tempDir, BlockingQueue<Long> queue, SymbolTable symbols, int maxNumberOfResults)
	Transaction(InterruptFlag interruptflag)

Uses of InterruptFlag in com.semedy.reasoner.reasoning

Methods in com.semedy.reasoner.reasoning with parameters of type InterruptFlag

Modifier and Type	Method	Description
void	ReasonerNotThreaded.register(InterruptFlag interruptFlag, EventResultReceiver receiver, CoreReadLock edbReadLock)
void	ReasonerNotThreaded.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock)
void	ReasonerThreadedFactsPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver)
void	ReasonerThreadedFactsPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock)
void	ReasonerThreadedFactsPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock, SimpleSemaphore semaphore)
void	ReasonerThreadedFactsPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, SimpleSemaphore semaphore)
void	ReasonerThreadedRulesPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver)
void	ReasonerThreadedRulesPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock)
void	ReasonerThreadedRulesPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, CoreReadLock edbReadLock, SimpleSemaphore semaphore)
void	ReasonerThreadedRulesPartitioning.register(InterruptFlag interruptFlag, List<EventResultReceiver> receiver, SimpleSemaphore semaphore)

Constructors in com.semedy.reasoner.reasoning with parameters of type InterruptFlag

Modifier	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)
	ReasonerThreadedFactsPartitioning(InterruptFlag interruptFlag, SymbolTable symboltable, BuiltinProvider builtinFactory, int reasoningthreads, ReasoningMonitor monitor, boolean skipAnswers, int maxNumberOfResults, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties)
	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)
	ReasoningFactsRegisterThread(InterruptFlag interruptFlag, SymbolTable symboltable, BuiltinProvider builtinFactory, boolean skipsendinganswers, EventResultReceiver receiver, CoreReadLock edbReadLock, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties, int pulsedTuples, boolean sorted, boolean skipAnswers)
	ReasoningFactsThread(InterruptFlag interruptFlag, Receiver receiver, SymbolTable symboltable, BuiltinProvider builtinFactory, boolean skipsendinganswers, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, boolean skipAnswers, Properties builtinProperties)
	ReasoningRulesThread(InterruptFlag interruptFlag, Receiver receiver, SymbolTable symboltable, BuiltinProvider builtinFactory, int reasoningthreads, ReasoningMonitor monitor, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties, int pulsedTuples, boolean sorted)
	ReasoningThread(InterruptFlag interruptFlag, Receiver receiver, ReasoningMonitor monitor, SymbolTable symboltable, BuiltinProvider builtinFactory, boolean skipsendinganswers, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, Properties builtinProperties, CoreLock corelock, int pulsedTuples, boolean sorted)

Uses of InterruptFlag in com.semedy.reasoner.reasoning.processes

Methods in com.semedy.reasoner.reasoning.processes with parameters of type InterruptFlag

Modifier and Type	Method	Description
JoinStatistics	ReasoningRelation.blockJoin(InterruptFlag interrupt, ReasoningRelation[] relations)
void	ProcessExecutor.evaluate(InterruptFlag interruptFlag, SimpleSemaphore semaphoreForSensors, CoreReadLock edbReadlock, Set<String> predicates)
JoinStatistics	ReasoningRelation.join(InterruptFlag interrupt, int[] compare1, ReasoningRelation R, int[] compare2, int[] source1, int[] dest1, int[] source2, int[] dest2, long[] externalFilter1, long[] externalFilter2, int destarity, Receiver receiver, com.semedy.reasoner.reasoning.processes.EvaluationThread evalThread, boolean streamReasoning, com.semedy.reasoner.reasoning.processes.SystemMonitor.JoinType joinType)

Constructors in com.semedy.reasoner.reasoning.processes with parameters of type InterruptFlag

Modifier	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)
	BinaryPattern(InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, BuiltinProvider builtinProvider, IntensionalDB idb, SymbolTable symbolTable, boolean streamReasoning, String queryKey, Properties builtinProperties, ExtensionalDB edb, boolean topDown)
	BodyPattern(InterruptFlag interruptFlag, IntensionalDB idb)
	BufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean cepReasoning, boolean cepReasoningWithRetracts, ProcessExecutor executor, boolean sorted)
	BufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)
	End(InterruptFlag interruptflag, int arity, ReasoningMonitor monitor)
	ExecuteAggregation(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, VariableHandler vh, int[] externalFilterPositions, long[] externalFilterValues, Aggregation aggregation, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning, String query)
	ExecuteConnectorBuiltin(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, VariableHandler vh, int[] externalFilterPositions, long[] externalFilterValues, Connector connector, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning, String query)
	ExecuteDirectFilterBuiltin(int i, InterruptFlag interruptFlag, VariableHandler vh, DirectFilterBuiltin builtin, ReasoningMonitor monitor)
	ExecuteFilterBuiltin(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, VariableHandler vh, FilterBuiltin builtin, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning)
	ExecuteFunctionalBuiltin(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, VariableHandler vh, FunctionalBuiltin builtin, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning, boolean notinternalize)
	ExecuteRelationalBuiltin(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, VariableHandler vh, RelationalBuiltin builtin, SymbolTable symboltable, RuleEvaluator reval, boolean cepReasoning)
	Match(int i, InterruptFlag interruptFlag, VariableHandler vh, Literal body, SymbolTable symboltable, ReasoningMonitor monitor)
	Not(int i, InterruptFlag interruptFlag, ReasoningMonitor monitor, SystemMonitor smonitor, VariableHandler vh, int[] externalFilterPositions, long[] externalFilterValues, RuleEvaluator reval, boolean cepReasoning, String query)
	ProcessExecutor(InterruptFlag interruptFlag, int maxstratum, int queryId)
	ProcessImp(InterruptFlag interruptFlag, int arity, ReasoningMonitor monitor)
	ProcessImp(InterruptFlag interruptFlag, ReasoningMonitor monitor)
	ResultReceiver(InterruptFlag interruptflag, Rule query, int arity, ReasoningMonitor monitor, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, long maxResults)
	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)
	RuleEvaluator(InterruptFlag interruptFlag, ReasoningMonitor monitor, Rule rule, Rule originalRule, Literal[] originalBodies, boolean extensional, boolean streamReasoning, ProcessExecutor pE, Schemas schemas)
	Scatter(InterruptFlag interruptFlag, int destarity, Rule rule, ReasoningMonitor monitor)
	SetConstants(InterruptFlag interruptFlag, int[] source, int[] dest, int[] groundpos, long[] groundterms, int destarity, Rule rule, ReasoningMonitor monitor)
	SubstituteFunction(int i, InterruptFlag interruptFlag, VariableHandler vh, Literal body, SymbolTable symboltable, ReasoningMonitor monitor)
	SynchronizedBufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)
	TestEqual(int i, InterruptFlag interruptFlag, VariableHandler variableHandler, Literal body, ReasoningMonitor monitor)
	TopDown(InterruptFlag interruptflag, int[] mapping, long[] groundterms, int[] groundpositions, int destarity, Literal topLiteral, Literal magic, ProcessExecutor executor, ReasoningMonitor monitor)
	TopDownBufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)
	TopDownTrigger(InterruptFlag interruptflag, Literal topLiteral, Literal magic, ReasoningMonitor monitor, boolean cepReasoning)
	TopDownUnbufferedStore(InterruptFlag interruptFlag, ReasoningMonitor monitor, int arity, String predicate, boolean not, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)
	UnbufferedStore(InterruptFlag interruptflag, ReasoningMonitor monitor, int arity, String predicate, boolean not, boolean cepReasoning, boolean cepReasoningWithRetracts, String tempDir, boolean swapping, ProcessExecutor executor, boolean sorted)
	VariableToVariable(int i, InterruptFlag interruptFlag, VariableHandler vh, Object[] arguments, ReasoningMonitor monitor)