TIndex
- the generic typepublic class TaggerConsumer<TIndex> extends AbstractSampleConsumer
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_TAG_LABEL |
Constructor and Description |
---|
TaggerConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
consume(Sample sample,
int channel)
Consumes the specified sample ton the specified channel.
|
SampleIndexer<TIndex> |
getSampleIndexer() |
String |
getTagLabel()
Gets the label of the tag used by this consumer.
|
void |
setSampleIndexer(SampleIndexer<TIndex> sampleIndexer) |
void |
setTagLabel(String tagLabel) |
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 static final String DEFAULT_TAG_LABEL
public final String getTagLabel()
public final void setTagLabel(String tagLabel)
public final SampleIndexer<TIndex> getSampleIndexer()
public final void setSampleIndexer(SampleIndexer<TIndex> sampleIndexer)
public void startConsuming()
SampleConsumer
public void consume(Sample sample, int channel)
SampleConsumer
sample
- The sample to be consumedchannel
- The channel on which the sample is consumedpublic void stopConsuming()
SampleConsumer
Copyright © 1998-2016 Apache Software Foundation. All Rights Reserved.