public class BaggingDistributorProcessor extends Object implements Processor
Constructor and Description |
---|
BaggingDistributorProcessor() |
Modifier and Type | Method and Description |
---|---|
int |
getEnsembleSize() |
Stream[] |
getOutputStreams() |
Processor |
newProcessor(Processor sourceProcessor)
Creates a copy of a processor.
|
void |
onCreate(int id)
Initializes the Processor.
|
boolean |
process(ContentEvent event)
On event.
|
void |
setEnsembleSize(int ensembleSize) |
void |
setOutputStreams(Stream[] ensembleStreams) |
public boolean process(ContentEvent event)
public void onCreate(int id)
Processor
process
method.public Stream[] getOutputStreams()
public void setOutputStreams(Stream[] ensembleStreams)
public int getEnsembleSize()
public void setEnsembleSize(int ensembleSize)
public Processor newProcessor(Processor sourceProcessor)
Processor
Processsor
.newProcessor
in interface Processor
sourceProcessor
- the processor to be copied.Processor
.Copyright © 2013–2015 The Apache Software Foundation. All rights reserved.