public class StreamingRegression extends StreamingProcess
Modifier and Type | Field and Description |
---|---|
Queue<Vector> |
samoaPredictions |
cepEvents, processTaskBuilder
Constructor and Description |
---|
StreamingRegression(int maxInstance,
int batchSize,
int parameterCount,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
Object[] |
getOutput() |
addEvents, run
public StreamingRegression(int maxInstance, int batchSize, int parameterCount, int parallelism)
public Object[] getOutput()
getOutput
in class StreamingProcess
Copyright © 2017 WSO2. All rights reserved.