TIndex
- the generic typepublic class TaggerConsumer<TIndex> extends AbstractSampleConsumer
Modifier and Type | Field and Description |
---|---|
static java.lang.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() |
java.lang.String |
getTagLabel()
Gets the label of the tag used by this consumer.
|
void |
setSampleIndexer(SampleIndexer<TIndex> sampleIndexer) |
void |
setTagLabel(java.lang.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 java.lang.String DEFAULT_TAG_LABEL
public final java.lang.String getTagLabel()
public final void setTagLabel(java.lang.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-2018 Apache Software Foundation. All Rights Reserved.