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

Class HadoopLongCounter

java.lang.Object

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

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

All Implemented Interfaces:

Externalizable, Serializable, HadoopCounter

public class HadoopLongCounter
extends HadoopCounterAdapter

Standard hadoop counter to use via original Hadoop API in Hadoop jobs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopLongCounter() Default constructor required by Externalizable.
HadoopLongCounter(String grp, String name) Constructor.

Method Summary

Modifier and Type	Method and Description
void	increment(long i) Increment this counter by the given value.
void	merge(HadoopCounter cntr)
protected void	readValue(ObjectInput in) Read value of this counter from input.
long	value() Gets current value of this counter.
void	value(long val) Sets current value by the given value.
protected void	writeValue(ObjectOutput out) Writes value of this counter to output.

Methods inherited from class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter

equals, group, hashCode, name, readExternal, toString, writeExternal

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopLongCounter

public HadoopLongCounter()

Default constructor required by Externalizable.

HadoopLongCounter

public HadoopLongCounter(String grp,
                         String name)

Constructor.

Parameters:

grp - Group name.

name - Counter name.

Method Detail

writeValue

protected void writeValue(ObjectOutput out)
                   throws IOException

Writes value of this counter to output.

Specified by:

writeValue in class HadoopCounterAdapter

Parameters:

out - Output.

Throws:

IOException - If failed.

readValue

protected void readValue(ObjectInput in)
                  throws IOException

Read value of this counter from input.

Specified by:

readValue in class HadoopCounterAdapter

Parameters:

in - Input.

Throws:

IOException - If failed.

merge

public void merge(HadoopCounter cntr)

value

public long value()

Gets current value of this counter.

Returns:

Current value.

value

public void value(long val)

Sets current value by the given value.

Parameters:

val - Value to set.

increment

public void increment(long i)

Increment this counter by the given value.

Parameters:

i - Value to increase this counter by.