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

Class HadoopPerformanceCounter

java.lang.Object

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

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

All Implemented Interfaces:

Externalizable, Serializable, HadoopCounter

public class HadoopPerformanceCounter
extends HadoopCounterAdapter

Counter for the job statistics accumulation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopPerformanceCounter() Default constructor required by Externalizable.
HadoopPerformanceCounter(String grp, String name) Constructor.
HadoopPerformanceCounter(UUID nodeId) Constructor to create instance to use this as helper.

Method Summary

Modifier and Type	Method and Description
void	clientSubmissionEvents(HadoopJobInfo info) Adds client submission events from job info.
Collection<T2<String,Long>>	evts() Gets the events collection.
static HadoopPerformanceCounter	getCounter(HadoopCounters cntrs, UUID nodeId) Gets system predefined performance counter from the HadoopCounters object.
void	merge(HadoopCounter cntr)
void	onJobPrepare(long ts) Adds event of the job preparation.
void	onJobStart(long ts) Adds event of the job start.
void	onShuffleMessage(int reducerNum, long ts) Registers shuffle message event.
void	onTaskFinish(HadoopTaskInfo info, long ts) Adds event of the task finish.
void	onTaskPrepare(HadoopTaskInfo info, long ts) Adds event of the task preparation.
void	onTaskStart(HadoopTaskInfo info, long ts) Adds event of the task run.
void	onTaskSubmit(HadoopTaskInfo info, long ts) Adds event of the task submission (task instance creation).
protected void	readValue(ObjectInput in) Read value of this counter from input.
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

HadoopPerformanceCounter

public HadoopPerformanceCounter()

Default constructor required by Externalizable.

HadoopPerformanceCounter

public HadoopPerformanceCounter(String grp,
                                String name)

Constructor.

Parameters:

grp - Group name.

name - Counter name.

HadoopPerformanceCounter

public HadoopPerformanceCounter(UUID nodeId)

Constructor to create instance to use this as helper.

Parameters:

nodeId - Id of the work node.

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)

evts

public Collection<T2<String,Long>> evts()

Gets the events collection.

Returns:

Collection of event.

onTaskSubmit

public void onTaskSubmit(HadoopTaskInfo info,
                         long ts)

Adds event of the task submission (task instance creation).

Parameters:

info - Task info.

ts - Timestamp of the event.

onTaskPrepare

public void onTaskPrepare(HadoopTaskInfo info,
                          long ts)

Adds event of the task preparation.

Parameters:

info - Task info.

ts - Timestamp of the event.

onTaskFinish

public void onTaskFinish(HadoopTaskInfo info,
                         long ts)

Adds event of the task finish.

Parameters:

info - Task info.

ts - Timestamp of the event.

onTaskStart

public void onTaskStart(HadoopTaskInfo info,
                        long ts)

Adds event of the task run.

Parameters:

info - Task info.

ts - Timestamp of the event.

onJobPrepare

public void onJobPrepare(long ts)

Adds event of the job preparation.

Parameters:

ts - Timestamp of the event.

onJobStart

public void onJobStart(long ts)

Adds event of the job start.

Parameters:

ts - Timestamp of the event.

clientSubmissionEvents

public void clientSubmissionEvents(HadoopJobInfo info)

Adds client submission events from job info.

Parameters:

info - Job info.

onShuffleMessage

public void onShuffleMessage(int reducerNum,
                             long ts)

Registers shuffle message event.

Parameters:

reducerNum - Number of reducer that receives the data.

ts - Timestamp of the event.

getCounter

public static HadoopPerformanceCounter getCounter(HadoopCounters cntrs,
                                                  @Nullable
                                                  UUID nodeId)

Gets system predefined performance counter from the HadoopCounters object.

Parameters:

cntrs - HadoopCounters object.

nodeId - Node id for methods that adds events. It may be null if you don't use ones.

Returns:

Predefined performance counter.