org.apache.giraph.block_app.framework.internal

Class BlockCounters

java.lang.Object

org.apache.giraph.block_app.framework.internal.BlockCounters

public class BlockCounters
extends Object

Utility class for Blocks Framework related counters

Field Summary

Fields

Modifier and Type	Field and Description
static String	GROUP

Method Summary

Modifier and Type	Method and Description
static Counter	getCounter(org.apache.hadoop.mapreduce.Mapper.Context context, String group, String name)
static Counter	getNoOpCounter()
static void	setMasterTimeCounter(PairedPieceAndStage<?> masterPiece, long superstep, long millis, StatusReporter reporter, BlockMasterLogic.TimeStatsPerEvent timeStats)
static void	setStageCounters(String prefix, Object stage, StatusReporter reporter) Takes all fields from stage object, and puts them into counters, if possible.
static void	setWorkerTimeCounter(BlockWorkerPieces<?> workerPieces, long superstep, long millis, StatusReporter reporter, BlockMasterLogic.TimeStatsPerEvent timeStats)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

GROUP

public static final String GROUP

See Also:

Constant Field Values

Method Detail

setStageCounters

public static void setStageCounters(String prefix,
                                    Object stage,
                                    StatusReporter reporter)

Takes all fields from stage object, and puts them into counters, if possible. Only fields that are convertible to long via widening are set (i.e. long/int/short/byte)

setMasterTimeCounter

public static void setMasterTimeCounter(PairedPieceAndStage<?> masterPiece,
                                        long superstep,
                                        long millis,
                                        StatusReporter reporter,
                                        BlockMasterLogic.TimeStatsPerEvent timeStats)

setWorkerTimeCounter

public static void setWorkerTimeCounter(BlockWorkerPieces<?> workerPieces,
                                        long superstep,
                                        long millis,
                                        StatusReporter reporter,
                                        BlockMasterLogic.TimeStatsPerEvent timeStats)

getCounter

public static Counter getCounter(org.apache.hadoop.mapreduce.Mapper.Context context,
                                 String group,
                                 String name)

getNoOpCounter

public static Counter getNoOpCounter()