org.apache.ignite.internal.processors.hadoop.impl

Class HadoopMapReduceCounters

java.lang.Object

org.apache.hadoop.mapreduce.counters.AbstractCounters<Counter,CounterGroup>

org.apache.hadoop.mapreduce.Counters

org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters

All Implemented Interfaces:

Iterable<CounterGroup>, Writable

public class HadoopMapReduceCounters
extends Counters

Hadoop counters adapter.

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.counters.AbstractCounters

LOG

Constructor Summary

Constructors

Constructor and Description
HadoopMapReduceCounters(HadoopCounters cntrs) Creates new instance based on given counters.

Method Summary

Modifier and Type	Method and Description
CounterGroup	addGroup(CounterGroup grp)
CounterGroup	addGroup(String name, String displayName)
int	countCounters()
boolean	equals(Object genericRight)
Counter	findCounter(Enum<?> key)
Counter	findCounter(String scheme, FileSystemCounter key)
Counter	findCounter(String grpName, String cntrName)
Counter	findCounter(String grpName, String cntrName, boolean create) Find a counter in the group.
CounterGroup	getGroup(String grpName)
Iterable<String>	getGroupNames()
boolean	getWriteAllCounters()
int	groupSize(String grpName) Returns size of a group.
int	hashCode()
void	incrAllCounters(AbstractCounters<Counter,CounterGroup> other)
Iterator<Counter>	iterateGroup(String grpName) Returns counters iterator for specified group.
Iterator<CounterGroup>	iterator()
Limits	limits()
void	readFields(DataInput in)
void	setWriteAllCounters(boolean snd)
void	write(DataOutput out)

Methods inherited from class org.apache.hadoop.mapreduce.counters.AbstractCounters

toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

HadoopMapReduceCounters

public HadoopMapReduceCounters(HadoopCounters cntrs)

Creates new instance based on given counters.

Parameters:

cntrs - Counters to adapt.

Method Detail

addGroup

public CounterGroup addGroup(CounterGroup grp)

Overrides:

addGroup in class AbstractCounters<Counter,CounterGroup>

addGroup

public CounterGroup addGroup(String name,
                             String displayName)

Overrides:

addGroup in class AbstractCounters<Counter,CounterGroup>

findCounter

public Counter findCounter(String grpName,
                           String cntrName)

Overrides:

findCounter in class AbstractCounters<Counter,CounterGroup>

findCounter

public Counter findCounter(Enum<?> key)

Overrides:

findCounter in class AbstractCounters<Counter,CounterGroup>

findCounter

public Counter findCounter(String scheme,
                           FileSystemCounter key)

Overrides:

findCounter in class AbstractCounters<Counter,CounterGroup>

getGroupNames

public Iterable<String> getGroupNames()

Overrides:

getGroupNames in class AbstractCounters<Counter,CounterGroup>

iterator

public Iterator<CounterGroup> iterator()

Specified by:

iterator in interface Iterable<CounterGroup>

Overrides:

iterator in class AbstractCounters<Counter,CounterGroup>

getGroup

public CounterGroup getGroup(String grpName)

Overrides:

getGroup in class AbstractCounters<Counter,CounterGroup>

countCounters

public int countCounters()

Overrides:

countCounters in class AbstractCounters<Counter,CounterGroup>

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface Writable

Overrides:

write in class AbstractCounters<Counter,CounterGroup>

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface Writable

Overrides:

readFields in class AbstractCounters<Counter,CounterGroup>

Throws:

IOException

incrAllCounters

public void incrAllCounters(AbstractCounters<Counter,CounterGroup> other)

Overrides:

incrAllCounters in class AbstractCounters<Counter,CounterGroup>

equals

public boolean equals(Object genericRight)

Overrides:

equals in class AbstractCounters<Counter,CounterGroup>

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCounters<Counter,CounterGroup>

setWriteAllCounters

public void setWriteAllCounters(boolean snd)

Overrides:

setWriteAllCounters in class AbstractCounters<Counter,CounterGroup>

getWriteAllCounters

public boolean getWriteAllCounters()

Overrides:

getWriteAllCounters in class AbstractCounters<Counter,CounterGroup>

limits

public Limits limits()

Overrides:

limits in class AbstractCounters<Counter,CounterGroup>

groupSize

public int groupSize(String grpName)

Returns size of a group.

Parameters:

grpName - Name of the group.

Returns:

amount of counters in the given group.

iterateGroup

public Iterator<Counter> iterateGroup(String grpName)

Returns counters iterator for specified group.

Parameters:

grpName - Name of the group to iterate.

Returns:

Counters iterator.

findCounter

public Counter findCounter(String grpName,
                           String cntrName,
                           boolean create)

Find a counter in the group.

Parameters:

grpName - The name of the counter group.

cntrName - The name of the counter.

create - Create the counter if not found if true.

Returns:

The counter that was found or added or null if create is false.