public class StreamingDistributor extends Object implements org.apache.samoa.learners.Learner, com.github.javacliparser.Configurable
Modifier and Type | Field and Description |
---|---|
com.github.javacliparser.IntOption |
intervalOption |
com.github.javacliparser.ClassOption |
learnerOption |
com.github.javacliparser.IntOption |
paralellismOption |
com.github.javacliparser.IntOption |
samplemOption |
Constructor and Description |
---|
StreamingDistributor() |
Modifier and Type | Method and Description |
---|---|
org.apache.samoa.core.Processor |
getInputProcessor() |
Set<org.apache.samoa.topology.Stream> |
getResultStreams() |
void |
init(org.apache.samoa.topology.TopologyBuilder builder,
org.apache.samoa.instances.Instances dataset,
int parallelism) |
protected void |
setLayout() |
public com.github.javacliparser.ClassOption learnerOption
public com.github.javacliparser.IntOption paralellismOption
public com.github.javacliparser.IntOption samplemOption
public com.github.javacliparser.IntOption intervalOption
public void init(org.apache.samoa.topology.TopologyBuilder builder, org.apache.samoa.instances.Instances dataset, int parallelism)
init
in interface org.apache.samoa.learners.Learner
protected void setLayout()
public org.apache.samoa.core.Processor getInputProcessor()
getInputProcessor
in interface org.apache.samoa.learners.Learner
public Set<org.apache.samoa.topology.Stream> getResultStreams()
getResultStreams
in interface org.apache.samoa.learners.Learner
Copyright © 2017 WSO2. All rights reserved.