public abstract class ProcessTask extends Object implements org.apache.samoa.tasks.Task, com.github.javacliparser.Configurable
Modifier and Type | Field and Description |
---|---|
com.github.javacliparser.IntOption |
batchDelayOption |
protected org.apache.samoa.topology.TopologyBuilder |
builder |
Queue<double[]> |
cepEvents |
com.github.javacliparser.FileOption |
dumpFileOption |
com.github.javacliparser.StringOption |
evaluationNameOption |
com.github.javacliparser.ClassOption |
evaluatorOption |
protected org.apache.samoa.streams.InstanceStream |
inputStream |
com.github.javacliparser.IntOption |
instanceLimitOption |
protected org.apache.samoa.learners.Learner |
learner |
com.github.javacliparser.ClassOption |
learnerOption |
com.github.javacliparser.IntOption |
sampleFrequencyOption |
com.github.javacliparser.FloatOption |
samplingThresholdOption |
protected SourceProcessor |
source |
com.github.javacliparser.IntOption |
sourceDelayOption |
protected org.apache.samoa.topology.Stream |
sourcePiOutputStream |
com.github.javacliparser.ClassOption |
streamTrainOption |
protected org.apache.samoa.topology.Topology |
topology |
Constructor and Description |
---|
ProcessTask() |
Modifier and Type | Method and Description |
---|---|
protected static org.apache.samoa.evaluation.PerformanceEvaluator |
getDefaultPerformanceEvaluatorForLearner(org.apache.samoa.learners.Learner learner) |
org.apache.samoa.topology.Topology |
getTopology() |
abstract void |
init() |
protected static boolean |
isLearnerAndEvaluatorCompatible(org.apache.samoa.learners.Learner learner,
org.apache.samoa.evaluation.PerformanceEvaluator evaluator) |
void |
setCepEvents(Queue<double[]> cepEvents) |
void |
setFactory(org.apache.samoa.topology.ComponentFactory factory) |
public com.github.javacliparser.ClassOption learnerOption
public com.github.javacliparser.ClassOption streamTrainOption
public com.github.javacliparser.ClassOption evaluatorOption
public com.github.javacliparser.IntOption sampleFrequencyOption
public com.github.javacliparser.StringOption evaluationNameOption
public com.github.javacliparser.FileOption dumpFileOption
public com.github.javacliparser.IntOption instanceLimitOption
public com.github.javacliparser.IntOption sourceDelayOption
public com.github.javacliparser.IntOption batchDelayOption
public com.github.javacliparser.FloatOption samplingThresholdOption
protected SourceProcessor source
protected org.apache.samoa.streams.InstanceStream inputStream
protected org.apache.samoa.topology.Stream sourcePiOutputStream
protected org.apache.samoa.learners.Learner learner
protected org.apache.samoa.topology.Topology topology
protected org.apache.samoa.topology.TopologyBuilder builder
public Queue<double[]> cepEvents
public abstract void init()
init
in interface org.apache.samoa.tasks.Task
public void setFactory(org.apache.samoa.topology.ComponentFactory factory)
setFactory
in interface org.apache.samoa.tasks.Task
protected static boolean isLearnerAndEvaluatorCompatible(org.apache.samoa.learners.Learner learner, org.apache.samoa.evaluation.PerformanceEvaluator evaluator)
protected static org.apache.samoa.evaluation.PerformanceEvaluator getDefaultPerformanceEvaluatorForLearner(org.apache.samoa.learners.Learner learner)
public org.apache.samoa.topology.Topology getTopology()
getTopology
in interface org.apache.samoa.tasks.Task
public void setCepEvents(Queue<double[]> cepEvents)
Copyright © 2017 WSO2. All rights reserved.