public class MapReduceStatistics extends Object
Constructor | Description |
---|---|
MapReduceStatisticsβ(int inputCount,
int outputCount,
int emitCount,
int duration) |
Construct a new instance.
|
Modifier and Type | Method | Description |
---|---|---|
int |
getDurationβ() |
Get the amount of time it took to run the map-reduce.
|
int |
getEmitCountβ() |
Get the number of messages emitted from the provided map function.
|
int |
getInputCountβ() |
Get the number of documents that were input into the map reduce operation
|
int |
getOutputCountβ() |
Get the number of documents generated as a result of this map reduce
|
public MapReduceStatisticsβ(int inputCount, int outputCount, int emitCount, int duration)
inputCount
- the input count.outputCount
- the output count.emitCount
- the emit count.duration
- the duration.public int getInputCountβ()
public int getOutputCountβ()
public int getEmitCountβ()
public int getDurationβ()