Package com.semedy.reasoner.reasoning.processes

Interface Process

All Superinterfaces:
Receiver
All Known Subinterfaces:
Store, TopDownStore
All Known Implementing Classes:
And, BufferedStore, EmptyEventResultReceiver, EmptyStore, End, EventResultReceiver, ExecuteAggregation, ExecuteConnectorBuiltin, ExecuteDirectFilterBuiltin, ExecuteFilterBuiltin, ExecuteFunctionalBuiltin, ExecuteRelationalBuiltin, Match, MaterializationReceiver, Not, ProcessImp, RuleEvaluator, Scatter, SetConstants, StoreEventResultReceiver, SubstituteFunction, SynchronizedBufferedStore, TestEqual, TopDown, TopDownBufferedStore, TopDownTrigger, TopDownUnbufferedStore, UnbufferedStore, VariableToVariable
public interface Process extends Receiver
Author:
angele

  • Method Details

    • getPriority

      int getPriority()
      get the priority of a process
      Returns:

    • evaluate

      void evaluate() throws InterruptedException, SemReasonerException, IOException
      evaluate a process during reasoning.
      Returns how the number of tuples sent away
      Throws:
      InterruptedException
      ReasoningException
      IOException
      SemReasonerException

    • setQueued

      void setQueued(boolean stacked)
      mark process as queued for reasoning
      Parameters:
      stacked -

    • isQueued

      boolean isQueued()
      is process queued for reasoning
      Returns:

    • isNotQueuedSetQueued

      boolean isNotQueuedSetQueued()
      If process is not queued for reasoning set it as queued for reasoning
      Returns:

    • setDataFlowGraph

      void setDataFlowGraph(ProcessExecutor processExecutor)
      set the executor for this process
      Parameters:
      processExecutor -

    • operationFinished

      void operationFinished() throws SemReasonerException
      this process is finished
      Throws:
      SemReasonerException

    • evaluationFinished

      void evaluationFinished(long querykey) throws IOException, SemReasonerException
      the whole evaluation is finished
      Parameters:
      querykey -
      Throws:
      ReasoningException
      IOException
      SemReasonerException

    • addRelation

      void addRelation(ReasoningRelation tuples) throws IOException, EDBException
      add a releation at the beginning
      Specified by:
      addRelation in interface Receiver
      Parameters:
      tuples - the relation to be added
      Throws:
      IOException
      EDBException

    • getArity

      int getArity()
      get the arity of tuples processed here
      Specified by:
      getArity in interface Receiver
      Returns:
      the arity of the receiver

    • addNextReceiver

      void addNextReceiver(Receiver n)
      attach a next receiver which receives input from this
      Parameters:
      n -

    • getTupleStore

      TupleStore getTupleStore()
      get the tuple store
      Specified by:
      getTupleStore in interface Receiver
      Returns:
      the tuple store

    • dispose

      void dispose()
      free ressources allocated by this process

    • setStratum

      void setStratum(int s)
      set the stratum of this process
      Parameters:
      s -

    • getStratum

      int getStratum()
      get the stratum
      Returns:

    • nextReceiver

      Receiver nextReceiver()
      get next process
      Returns:

    • clear

      void clear() throws IOException
      free up ressources
      Throws:
      IOException