Package ca.uqac.lif.cep.json

Class SpliceJsonStreamSource

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.tmf.Source
ca.uqac.lif.cep.io.SpliceSource
ca.uqac.lif.cep.json.SpliceJsonStreamSource
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class SpliceJsonStreamSource extends ca.uqac.lif.cep.io.SpliceSource
A splice source that reads a JSONStream document and produces a stream of JSON elements.
Since:
0.8
Author:
Sylvain Hallé

  • Nested Class Summary

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.io.SpliceSource

    ca.uqac.lif.cep.io.SpliceSource.SpliceByteSource, ca.uqac.lif.cep.io.SpliceSource.SpliceLineSource, ca.uqac.lif.cep.io.SpliceSource.SpliceTokenSource

    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 inherited from class ca.uqac.lif.cep.io.SpliceSource

    m_sources, m_streamIndex

    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_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

  • Constructor Summary

    Constructors
    Constructor
    Description
    SpliceJsonStreamSource(boolean read_stdin, String... filenames)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected ca.uqac.lif.cep.Processor
    getSource(String filename)
     

    Methods inherited from class ca.uqac.lif.cep.io.SpliceSource

    compute, duplicate, getNextEvent, start, stop

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

    push

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

    getPullableOutput, getPushableInput

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

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, onEndOfTrace, or, or, or, printState, readState, reset, rightShift, setContext, setContext, setPullableInput, setPushableOutput, startAll, stopAll

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SpliceJsonStreamSource

      public SpliceJsonStreamSource(boolean read_stdin, String... filenames)

  • Method Details

    • getSource

      protected ca.uqac.lif.cep.Processor getSource(String filename)
      Specified by:
      getSource in class ca.uqac.lif.cep.io.SpliceSource