public abstract class StreamingProcess extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
Queue<double[]> |
cepEvents |
protected TaskBuilder |
processTaskBuilder |
Constructor and Description |
---|
StreamingProcess() |
Modifier and Type | Method and Description |
---|---|
void |
addEvents(double[] eventData) |
abstract Object[] |
getOutput() |
void |
run() |
public Queue<double[]> cepEvents
protected TaskBuilder processTaskBuilder
Copyright © 2017 WSO2. All rights reserved.