org.apache.ignite.internal.processors.hadoop.counter

Class HadoopCountersImpl

java.lang.Object

org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl

All Implemented Interfaces:

Externalizable, Serializable, HadoopCounters

public class HadoopCountersImpl
extends Object
implements HadoopCounters, Externalizable

Default in-memory counters store.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopCountersImpl() Default constructor.
HadoopCountersImpl(HadoopCounters cntrs) Copy constructor.
HadoopCountersImpl(Iterable<HadoopCounter> cntrs) Creates new instance that contain given counters.

Method Summary

Modifier and Type	Method and Description
Collection<HadoopCounter>	all()
<T extends HadoopCounter> T	counter(String grp, String name, Class<T> cls)
boolean	equals(Object o)
int	hashCode()
void	merge(HadoopCounters other)
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopCountersImpl

public HadoopCountersImpl()

Default constructor. Creates new instance without counters.

HadoopCountersImpl

public HadoopCountersImpl(Iterable<HadoopCounter> cntrs)

Creates new instance that contain given counters.

Parameters:

cntrs - Counters to store.

HadoopCountersImpl

public HadoopCountersImpl(HadoopCounters cntrs)

Copy constructor.

Parameters:

cntrs - Counters to copy.

Method Detail

counter

public <T extends HadoopCounter> T counter(String grp,
                                           String name,
                                           Class<T> cls)

Specified by:

counter in interface HadoopCounters

all

public Collection<HadoopCounter> all()

Specified by:

all in interface HadoopCounters

merge

public void merge(HadoopCounters other)

Specified by:

merge in interface HadoopCounters

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object