public class MapReduceStatistics
extends java.lang.Object
Constructor and Description |
---|
MapReduceStatistics(int inputCount,
int outputCount,
int emitCount,
int duration)
Construct a new instance.
|
Modifier and Type | Method and 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()