Package ca.uqac.lif.cep.json

Class JsonLineFeeder

  • 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
    public class JsonLineFeeder
extends ca.uqac.lif.cep.tmf.Source
    A source of JSON events taking its data from a JSON file. To facilitate parsing, the source expects one complete JSON snippet per text line.
    Since:
    0.8
    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 java.io.InputStream m_is
      The input stream to read JSON content from.
      protected java.util.Scanner m_scanner
      The scanner pulling lines from the input stream.
      protected static ca.uqac.lif.json.JsonParser s_parser
      The parser used to parse the elements.

      • 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
      JsonLineFeeder​(java.io.InputStream is)
      Creates a new instance of the source, by providing an input stream to read text from.

    • 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)  
      JsonLineFeeder duplicate​(boolean with_state)  
      void stop()  

      • Methods inherited from class ca.uqac.lif.cep.tmf.Source

        push

      • 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, setContext, setContext, setPullableInput, setPushableOutput, start, startAll, stopAll

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • s_parser

        protected static final ca.uqac.lif.json.JsonParser s_parser
        The parser used to parse the elements. All instances of the processor share the same parser.

      • m_is

        protected final java.io.InputStream m_is
        The input stream to read JSON content from.

      • m_scanner

        protected final java.util.Scanner m_scanner
        The scanner pulling lines from the input stream.

    • Constructor Detail

      • JsonLineFeeder

        public JsonLineFeeder​(java.io.InputStream is)
        Creates a new instance of the source, by providing an input stream to read text from.
        Parameters:
        is - The input stream

    • 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 JsonLineFeeder duplicate​(boolean with_state)
        Specified by:
        duplicate in interface ca.uqac.lif.cep.Duplicable
        Specified by:
        duplicate in class ca.uqac.lif.cep.Processor

      • stop

        public void stop()
        Overrides:
        stop in class ca.uqac.lif.cep.Processor