public class NormalizerSampleConsumer extends AbstractSampleConsumer
SampleSaveConfiguration.MILLISECONDS
) and reproduce them as a long
value (for faster treatment later in the consuming chain).Constructor and Description |
---|
NormalizerSampleConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
consume(Sample s,
int channel)
Consumes the specified sample ton the specified channel.
|
void |
startConsuming()
Start the sample consuming.
|
void |
stopConsuming()
Stops the consuming process.
|
addSampleConsumer, getConsumedChannelCount, getConsumedMetadata, getConsumer, getDataFromContext, getName, getWorkingDirectory, produce, removeSampleConsumer, setChannelAttribute, setConsumedMetadata, setDataToContext, setName, setProducedMetadata, setSampleConsumer, setSampleConsumers, setSampleContext, startProducing, stopProducing
getChannelAttribute, getSampleContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChannelAttribute, getSampleContext
public void startConsuming()
SampleConsumer
public void consume(Sample s, int channel)
SampleConsumer
s
- The sample to be consumedchannel
- The channel on which the sample is consumedpublic void stopConsuming()
SampleConsumer
Copyright © 1998-2019 Apache Software Foundation. All Rights Reserved.