public class StreamingRegressionTaskBuilder extends TaskBuilder
Modifier and Type | Field and Description |
---|---|
int |
batchSize |
int |
parallelism |
Queue<Vector> |
samoaPredictions |
cepEvents, maxEvents, numberOfAttributes, STATUS_UPDATE_FREQ_MSG, SUPPRESS_RESULT_OUT_MSG, SUPPRESS_STATUS_OUT_MSG, topology
Constructor and Description |
---|
StreamingRegressionTaskBuilder(int maxInstance,
int batchSize,
int numAtts,
Queue<double[]> cepEvents,
Queue<Vector> data,
int parallel) |
Modifier and Type | Method and Description |
---|---|
void |
initTask() |
submit
public void initTask()
initTask
in class TaskBuilder
Copyright © 2017 WSO2. All rights reserved.