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()