Package | Description |
---|---|
org.apache.hadoop.mapred |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.counters |
This package contains the implementations of different types of
map-reduce counters.
|
org.apache.hadoop.mapreduce.lib.map | |
org.apache.hadoop.mapreduce.lib.reduce | |
org.apache.hadoop.mapreduce.task | |
org.apache.hadoop.mapreduce.util |
Modifier and Type | Class and Description |
---|---|
static class |
Counters.Counter
Deprecated.
A counter record, comprising its name and value.
|
Modifier and Type | Method and Description |
---|---|
Counter |
TaskAttemptContextImpl.getCounter(java.lang.Enum<?> counterName)
Deprecated.
|
Counter |
TaskAttemptContextImpl.getCounter(java.lang.String groupName,
java.lang.String counterName)
Deprecated.
|
Counter |
Counters.Counter.getUnderlyingCounter() |
Modifier and Type | Method and Description |
---|---|
protected static <INKEY,INVALUE,OUTKEY,OUTVALUE> |
Task.createReduceContext(Reducer<INKEY,INVALUE,OUTKEY,OUTVALUE> reducer,
org.apache.hadoop.conf.Configuration job,
TaskAttemptID taskId,
RawKeyValueIterator rIter,
Counter inputKeyCounter,
Counter inputValueCounter,
RecordWriter<OUTKEY,OUTVALUE> output,
OutputCommitter committer,
StatusReporter reporter,
org.apache.hadoop.io.RawComparator<INKEY> comparator,
java.lang.Class<INKEY> keyClass,
java.lang.Class<INVALUE> valueClass) |
Modifier and Type | Method and Description |
---|---|
Counter |
TaskAttemptContext.getCounter(java.lang.Enum<?> counterName)
Get the
Counter for the given counterName . |
abstract Counter |
StatusReporter.getCounter(java.lang.Enum<?> name) |
Counter |
TaskAttemptContext.getCounter(java.lang.String groupName,
java.lang.String counterName)
|
abstract Counter |
StatusReporter.getCounter(java.lang.String group,
java.lang.String name) |
Counter |
Counter.getUnderlyingCounter()
Return the underlying object if this is a facade.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCounterGroup<T extends Counter>
An abstract class to provide common implementation of the
generic counter group in both mapred and mapreduce package.
|
class |
AbstractCounters<C extends Counter,G extends CounterGroupBase<C>>
An abstract class to provide common implementation for the Counters
container in both mapred and mapreduce packages.
|
interface |
CounterGroupBase<T extends Counter>
The common counter group interface.
|
class |
CounterGroupFactory<C extends Counter,G extends CounterGroupBase<C>>
An abstract class to provide common implementation of the
group factory in both mapred and mapreduce packages.
|
class |
FileSystemCounterGroup<C extends Counter>
An abstract class to provide common implementation of the filesystem
counter group in both mapred and mapreduce packages.
|
class |
FrameworkCounterGroup<T extends java.lang.Enum<T>,C extends Counter>
An abstract class to provide common implementation for the framework
counter group in both mapred and mapreduce packages.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCounter
An abstract counter class to provide common implementation of
the counter interface in both mapred and mapreduce packages.
|
class |
FileSystemCounterGroup.FSCounter |
class |
FrameworkCounterGroup.FrameworkCounter
A counter facade for framework counters.
|
class |
GenericCounter
A generic counter implementation
|
Modifier and Type | Method and Description |
---|---|
Counter |
FileSystemCounterGroup.FSCounter.getUnderlyingCounter() |
Counter |
FrameworkCounterGroup.FrameworkCounter.getUnderlyingCounter() |
Counter |
GenericCounter.getUnderlyingCounter() |
Modifier and Type | Method and Description |
---|---|
Counter |
WrappedMapper.Context.getCounter(java.lang.Enum<?> counterName) |
Counter |
WrappedMapper.Context.getCounter(java.lang.String groupName,
java.lang.String counterName) |
Modifier and Type | Method and Description |
---|---|
Counter |
WrappedReducer.Context.getCounter(java.lang.Enum counterName) |
Counter |
WrappedReducer.Context.getCounter(java.lang.String groupName,
java.lang.String counterName) |
Modifier and Type | Method and Description |
---|---|
Counter |
TaskAttemptContextImpl.getCounter(java.lang.Enum<?> counterName) |
Counter |
TaskAttemptContextImpl.DummyReporter.getCounter(java.lang.Enum<?> name) |
Counter |
TaskAttemptContextImpl.getCounter(java.lang.String groupName,
java.lang.String counterName) |
Counter |
TaskAttemptContextImpl.DummyReporter.getCounter(java.lang.String group,
java.lang.String name) |
Constructor and Description |
---|
ReduceContextImpl(org.apache.hadoop.conf.Configuration conf,
TaskAttemptID taskid,
RawKeyValueIterator input,
Counter inputKeyCounter,
Counter inputValueCounter,
RecordWriter<KEYOUT,VALUEOUT> output,
OutputCommitter committer,
StatusReporter reporter,
org.apache.hadoop.io.RawComparator<KEYIN> comparator,
java.lang.Class<KEYIN> keyClass,
java.lang.Class<VALUEIN> valueClass) |
Modifier and Type | Method and Description |
---|---|
static <C extends Counter,G extends CounterGroupBase<C>,T extends AbstractCounters<C,G>> |
CountersStrings.parseEscapedCompactString(java.lang.String compactString,
T counters)
Parse a pre 0.21 counters string into a counter object.
|
static <C extends Counter,G extends CounterGroupBase<C>,T extends AbstractCounters<C,G>> |
CountersStrings.toEscapedCompactString(T counters)
Make the pre 0.21 counters string
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
CountersStrings.toEscapedCompactString(Counter counter)
Make the pre 0.21 counter string (for e.g.
|
Copyright © 2009 The Apache Software Foundation