org.wso2.extension.siddhi.execution.ml.samoa.utils

## Class StreamingProcess

- java.lang.Object
- - org.wso2.extension.siddhi.execution.ml.samoa.utils.StreamingProcess

- All Implemented Interfaces:
    Runnable
  Direct Known Subclasses:
    StreamingClassification, StreamingClustering, StreamingRegression

      public abstract class StreamingProcess
      extends Object
      implements Runnable

  Streaming Process

- - ### Field Summary

    Fields
    Modifier and Type | Field and Description
    --- | ---
    `Queue<double[]>` | `cepEvents`
    `protected TaskBuilder` | `processTaskBuilder`

  - ### Constructor Summary

    Constructors
    Constructor and Description
    `StreamingProcess()`

  - ### Method Summary

    All Methods Instance Methods Abstract Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `addEvents(double[] eventData)`
    `abstract Object[]` | `getOutput()`
    `void` | `run()`

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Field Detail

    - #### cepEvents

          public Queue<double[]> cepEvents

    - #### processTaskBuilder

          protected TaskBuilder processTaskBuilder

  - ### Constructor Detail

    - #### StreamingProcess

          public StreamingProcess()

  - ### Method Detail

    - #### getOutput

          public abstract Object[] getOutput()

    - #### run

          public void run()

      Specified by:
        `run` in interface `Runnable`

    - #### addEvents

          public void addEvents(double[] eventData)

Copyright © 2017 WSO2. All rights reserved.