public class BenchmarkCounter extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BenchmarkCounter.NullCounter |
Constructor and Description |
---|
BenchmarkCounter() |
Modifier and Type | Method and Description |
---|---|
static long |
getBytesRead() |
static long |
getTime() |
static long |
getTotalBytes() |
static void |
incrementBytesRead(long val) |
static void |
incrementTime(long val) |
static void |
incrementTotalBytes(long val) |
static void |
initCounterFromContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
Init counters in hadoop's mapreduce API, support both 1.x and 2.x
|
static void |
initCounterFromReporter(org.apache.hadoop.mapred.Reporter reporter,
org.apache.hadoop.conf.Configuration configuration)
Init counters in hadoop's mapred API, which is used by cascading and Hive.
|
public static void initCounterFromContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
context
- public static void initCounterFromReporter(org.apache.hadoop.mapred.Reporter reporter, org.apache.hadoop.conf.Configuration configuration)
reporter
- configuration
- public static void incrementTotalBytes(long val)
public static long getTotalBytes()
public static void incrementBytesRead(long val)
public static long getBytesRead()
public static void incrementTime(long val)
public static long getTime()
Copyright © 2015. All rights reserved.