public interface Learner extends Serializable
Processor
, connect the Learner with the input stream, and initialize the result stream so that other processors
can subscribe to the results of this learner.Modifier and Type | Method and Description |
---|---|
Processor |
getInputProcessor()
Gets the input processing item.
|
Set<Stream> |
getResultStreams()
Gets the result streams
|
void |
init(TopologyBuilder topologyBuilder,
Instances dataset,
int parallelism)
Inits the Learner object.
|
void init(TopologyBuilder topologyBuilder, Instances dataset, int parallelism)
topologyBuilder
- the topology builderdataset
- the datasetparallelism
- the parallelismProcessor getInputProcessor()
Copyright © 2013–2015 The Apache Software Foundation. All rights reserved.