public class StreamingClassificationTaskBuilder extends TaskBuilder
Modifier and Type | Field and Description |
---|---|
Queue<Vector> |
classifiers |
protected static org.slf4j.Logger |
LOGGER |
cepEvents, maxEvents, numberOfAttributes, STATUS_UPDATE_FREQ_MSG, SUPPRESS_RESULT_OUT_MSG, SUPPRESS_STATUS_OUT_MSG, topology
Constructor and Description |
---|
StreamingClassificationTaskBuilder(int maxInstance,
int batchSize,
int numClasses,
int numAtts,
int numNominals,
String nominalVals,
Queue<double[]> cepEvents,
Queue<Vector> classifiers,
int parallelism,
int bagging) |
Modifier and Type | Method and Description |
---|---|
protected void |
initClassificationTask(String[] args) |
void |
initTask() |
submit
public void initTask()
initTask
in class TaskBuilder
protected void initClassificationTask(String[] args)
Copyright © 2017 WSO2. All rights reserved.