Uses of Interface
com.semedy.reasoner.api.reasoning.Receiver
Package
Description
-
Uses of Receiver in com.semedy.reasoner.api.builtin
-
Uses of Receiver in com.semedy.reasoner.api.core
Modifier and TypeClassDescriptionclass
A receiver for results caused by eventsclass
Stores results during materialization in edb
Single events are buffered until reasoning is finished.class
Stores results during materialization in edb
Single events are buffered until reasoning is finished.Modifier and TypeMethodDescriptionMaterializationReceiver.startTuples
(Receiver source, boolean check4Duplicates) Modifier and TypeMethodDescriptionMaterializationReceiver.startTuples
(Receiver source, boolean check4Duplicates) -
Uses of Receiver in com.semedy.reasoner.api.reasoning
Modifier and TypeMethodDescriptionReceiver.startTuples
(Receiver source, boolean check4Duplicates) start delivering single tuplesModifier and TypeMethodDescriptionvoid
Starts evaluation and feed the results into receiverReceiver.startTuples
(Receiver source, boolean check4Duplicates) start delivering single tuples -
Uses of Receiver in com.semedy.reasoner.builtin
Modifier and TypeInterfaceDescriptioninterface
interface for a direct filter builtin. -
Uses of Receiver in com.semedy.reasoner.builtin.directfilter
Modifier and TypeClassDescriptionclass
class
class
class
Determines whether second argument is NOT functional dependent on first argument.class
Determines whether second argument is NOT functional dependent on first argument.Modifier and TypeMethodDescriptionIsNotFunctional2.startTuples
(Receiver source, boolean check4Duplicates) IsNotFunctional3.startTuples
(Receiver source, boolean check4Duplicates) Modifier and TypeMethodDescriptionIsNotFunctional2.startTuples
(Receiver source, boolean check4Duplicates) IsNotFunctional3.startTuples
(Receiver source, boolean check4Duplicates) -
Uses of Receiver in com.semedy.reasoner.core
Modifier and TypeMethodDescriptionIntermediateResultProducer.startTuples
(Receiver source, boolean check4Duplicates) Modifier and TypeMethodDescriptionIntermediateResultProducer.startTuples
(Receiver source, boolean check4Duplicates) -
Uses of Receiver in com.semedy.reasoner.reasoning
Modifier and TypeMethodDescriptionvoid
void
void
ModifierConstructorDescriptionReasoningFactsThread
(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 Receiver in com.semedy.reasoner.reasoning.processes
Modifier and TypeClassDescriptionclass
class
Stores intermediate results: results between two rule bodies or results of rule evaluations
For recursive rules or recursion cycles results must be buffered.class
An empty store, i.E. all incoming tuples are thrown awayclass
Takes a package of input tuples and internalizes terms in it.class
a cap for a dead end in the data flow graphclass
Receiver wrapper for callbacks for the results of sensor triggered reasoning resultsclass
class
class
class
class
class
class
class
class
Represents a process in the operator net.class
container which collects reasoning resultsclass
class
class
class
class
Stores intermediate results: results between two rule bodies or results of rule evaluations
For recursive rules or recursion cycles results must be buffered.class
class
propagates intermediate results top downclass
class
triggers bottom-up evaluation of ruleclass
class
A store with an unbuffered input.class
Modifier and TypeMethodDescriptionEmptyStore.nextReceiver()
Process.nextReceiver()
get next processProcessImp.nextReceiver()
EmptyStore.startTuples
(Receiver source, boolean check4Duplicates) Encoder.startTuples
(Receiver source, boolean check4Duplicates) End.startTuples
(Receiver source, boolean check4Duplicates) EventReceiver.startTuples
(Receiver source, boolean check4Duplicates) ProcessImp.startTuples
(Receiver source, boolean check4Duplicates) ResultReceiver.startTuples
(Receiver source, boolean check4Duplicates) Scatter.startTuples
(Receiver source, boolean check4Duplicates) SetConstants.startTuples
(Receiver source, boolean check4Duplicates) Store.startTuples
(Receiver source, boolean check4Duplicates) a process which delivers single tuples startsSynchronizedBufferedStore.startTuples
(Receiver source, boolean check4Duplicates) UnbufferedStore.startTuples
(Receiver source, boolean check4Duplicates) Modifier and TypeMethodDescriptionTopDownBufferedStore.getBottomNeighbours()
TopDownStore.getBottomNeighbours()
TopDownUnbufferedStore.getBottomNeighbours()
Scatter.getNeighbours()
Modifier and TypeMethodDescriptionvoid
TopDownBufferedStore.addBottomNeighbour
(Receiver op) void
TopDownStore.addBottomNeighbour
(Receiver op) void
TopDownUnbufferedStore.addBottomNeighbour
(Receiver op) void
EmptyStore.addNextReceiver
(Receiver n) void
Process.addNextReceiver
(Receiver n) attach a next receiver which receives input from thisvoid
ProcessImp.addNextReceiver
(Receiver n) void
Scatter.addNextReceiver
(Receiver n) void
RuleCompiler.attachReceiver
(Receiver receiver, ExtensionalDB temporaryEDB) attach a receiver to the ith query to process net which gets the results of the evaluationReasoningRelation.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) void
Encoder.setNextReceiver
(Receiver next) EmptyStore.startTuples
(Receiver source, boolean check4Duplicates) Encoder.startTuples
(Receiver source, boolean check4Duplicates) End.startTuples
(Receiver source, boolean check4Duplicates) EventReceiver.startTuples
(Receiver source, boolean check4Duplicates) ProcessImp.startTuples
(Receiver source, boolean check4Duplicates) ResultReceiver.startTuples
(Receiver source, boolean check4Duplicates) Scatter.startTuples
(Receiver source, boolean check4Duplicates) SetConstants.startTuples
(Receiver source, boolean check4Duplicates) Store.startTuples
(Receiver source, boolean check4Duplicates) a process which delivers single tuples startsSynchronizedBufferedStore.startTuples
(Receiver source, boolean check4Duplicates) UnbufferedStore.startTuples
(Receiver source, boolean check4Duplicates) Modifier and TypeMethodDescriptionvoid
RuleCompiler.attachReceiver
(List<Receiver> receiver, ExtensionalDB temporaryEDB) attach a receiver to process net which gets the results of the evaluation