TData
- the type of data to processpublic abstract class AbstractSummaryConsumer<TData> extends AbstractSampleConsumer
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractSummaryConsumer.SummaryInfo
The class SummaryInfo stores intermediate results.
|
Modifier and Type | Field and Description |
---|---|
static String |
RESULT_VALUE_DATA |
static String |
RESULT_VALUE_IS_CONTROLLER |
static String |
RESULT_VALUE_ITEMS |
static String |
RESULT_VALUE_OVERALL |
static String |
RESULT_VALUE_SUPPORTS_CONTROLLERS_DISCRIMINATION |
static String |
RESULT_VALUE_TITLES |
Modifier | Constructor and Description |
---|---|
protected |
AbstractSummaryConsumer(boolean supportsControllersDiscrimination)
Instantiates a new abstract summary consumer.
|
Modifier and Type | Method and Description |
---|---|
void |
consume(Sample sample,
int channel)
Consumes the specified sample ton the specified channel.
|
protected abstract ListResultData |
createDataResult(String key,
TData data)
Creates a result item for information identified by the specified key.
|
protected abstract ListResultData |
createResultTitles()
Creates the result containing titles of columns.
|
protected abstract String |
getKeyFromSample(Sample sample)
Gets the identifier key from sample.
|
protected AbstractSummaryConsumer.SummaryInfo |
getOverallInfo()
Gets the overall info.
|
protected Map<String,AbstractSummaryConsumer.SummaryInfo> |
getSummaryInfos()
Gets the summary infos.
|
boolean |
hasOverallResult()
Defines whether the result contains an overall item.
|
void |
setHasOverallResult(boolean hasOverallResult)
Defines whether the result contains an overall item.
|
void |
startConsuming()
Start the sample consuming.
|
void |
stopConsuming()
Stops the consuming process.
|
boolean |
suppportsControllersDiscrimination()
Indicates whether this summary can discriminate controller samples
|
protected abstract void |
updateData(AbstractSummaryConsumer.SummaryInfo info,
Sample sample)
Update the stored data with the data from the specified sample.
|
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 RESULT_VALUE_DATA
public static final String RESULT_VALUE_IS_CONTROLLER
public static final String RESULT_VALUE_ITEMS
public static final String RESULT_VALUE_OVERALL
public static final String RESULT_VALUE_SUPPORTS_CONTROLLERS_DISCRIMINATION
public static final String RESULT_VALUE_TITLES
protected AbstractSummaryConsumer(boolean supportsControllersDiscrimination)
supportsControllersDiscrimination
- indicates whether this summary can discriminate controller
samplespublic final boolean hasOverallResult()
public final void setHasOverallResult(boolean hasOverallResult)
hasOverallResult
- true, if the result contains an overall item; false otherwisepublic final boolean suppportsControllersDiscrimination()
protected final AbstractSummaryConsumer.SummaryInfo getOverallInfo()
protected final Map<String,AbstractSummaryConsumer.SummaryInfo> getSummaryInfos()
protected abstract String getKeyFromSample(Sample sample)
sample
- the sampleprotected abstract ListResultData createDataResult(String key, TData data)
key
- the keydata
- the dataprotected abstract ListResultData createResultTitles()
protected abstract void updateData(AbstractSummaryConsumer.SummaryInfo info, Sample sample)
sample
- the samplepublic 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.