Package ca.uqac.lif.cep.hibernate

Class Hibernate

  • All Implemented Interfaces:
    ca.uqac.lif.azrael.Printable, ca.uqac.lif.azrael.Readable, ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
    Direct Known Subclasses:
    FileHibernate
    public class Hibernate
extends ca.uqac.lif.cep.SynchronousProcessor
    Stores an internal processor using an object fridge.
    Author:
    Sylvain Hallé

    • Nested Class Summary

      • Nested classes/interfaces inherited from class ca.uqac.lif.cep.SynchronousProcessor

        ca.uqac.lif.cep.SynchronousProcessor.InputPushable, ca.uqac.lif.cep.SynchronousProcessor.OutputPullable

      • Nested classes/interfaces inherited from class ca.uqac.lif.cep.Processor

        ca.uqac.lif.cep.Processor.InternalProcessorState

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected ca.uqac.lif.azrael.fridge.Fridge m_fridge
      A fridge used to store the processor
      protected java.util.List<java.util.Queue<java.lang.Object>> m_queues
      Each of the queues contained in the sink (one for each output pipe)
      protected ca.uqac.lif.cep.tmf.QueueSink m_sink
      A sink to receive the events produced by the processor

      • Fields inherited from class ca.uqac.lif.cep.SynchronousProcessor

        m_inputPushables, m_outputPullables, m_tempQueue

      • Fields inherited from class ca.uqac.lif.cep.Processor

        m_context, m_eventTracker, m_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputCount, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputCount, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

    • Constructor Summary

      Constructors 
      Constructor Description
      Hibernate​(ca.uqac.lif.cep.Processor p, ca.uqac.lif.azrael.fridge.Fridge f)
      Creates a new hibernate processor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected boolean compute​(java.lang.Object[] inputs, java.util.Queue<java.lang.Object[]> outputs)  
      ca.uqac.lif.cep.Processor duplicate​(boolean with_state)  
      protected ca.uqac.lif.azrael.fridge.Fridge getFridge()
      Gets an instance of fridge
      void setContext​(ca.uqac.lif.cep.Context c)  
      void setContext​(java.lang.String key, java.lang.Object value)  

      • Methods inherited from class ca.uqac.lif.cep.SynchronousProcessor

        getPullableOutput, getPushableInput, setEventTracker

      • Methods inherited from class ca.uqac.lif.cep.Processor

        allNotifiedEndOfTrace, allNull, associateTo, associateToInput, associateToOutput, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getEventTracker, getId, getInputArity, getInputCount, getInputQueue, getInputType, getInputTypesFor, getLeaves, getLeaves, getOutputArity, getOutputCount, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, onEndOfTrace, or, or, print, printState, read, readState, reset, rightShift, setPullableInput, setPushableOutput, start, startAll, stop, stopAll

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • m_fridge

        protected ca.uqac.lif.azrael.fridge.Fridge m_fridge
        A fridge used to store the processor

      • m_sink

        protected ca.uqac.lif.cep.tmf.QueueSink m_sink
        A sink to receive the events produced by the processor

      • m_queues

        protected java.util.List<java.util.Queue<java.lang.Object>> m_queues
        Each of the queues contained in the sink (one for each output pipe)

    • Constructor Detail

      • Hibernate

        public Hibernate​(ca.uqac.lif.cep.Processor p,
                 ca.uqac.lif.azrael.fridge.Fridge f)
        Creates a new hibernate processor
        Parameters:
        p - The processor to hibernate
        f - The fridge used to store the processor. The fridge must already store the processor.

    • Method Detail

      • compute

        protected boolean compute​(java.lang.Object[] inputs,
                          java.util.Queue<java.lang.Object[]> outputs)
        Specified by:
        compute in class ca.uqac.lif.cep.SynchronousProcessor

      • duplicate

        public ca.uqac.lif.cep.Processor duplicate​(boolean with_state)
        Specified by:
        duplicate in interface ca.uqac.lif.cep.Duplicable
        Specified by:
        duplicate in class ca.uqac.lif.cep.Processor

      • getFridge

        protected ca.uqac.lif.azrael.fridge.Fridge getFridge()
        Gets an instance of fridge
        Returns:
        The fridge

      • setContext

        public void setContext​(ca.uqac.lif.cep.Context c)
        Specified by:
        setContext in interface ca.uqac.lif.cep.Contextualizable
        Overrides:
        setContext in class ca.uqac.lif.cep.Processor

      • setContext

        public void setContext​(java.lang.String key,
                       java.lang.Object value)
        Specified by:
        setContext in interface ca.uqac.lif.cep.Contextualizable
        Overrides:
        setContext in class ca.uqac.lif.cep.Processor