alluxio.master.job.metrics

Class DistributedCmdMetrics

java.lang.Object

alluxio.master.job.metrics.DistributedCmdMetrics

public class DistributedCmdMetrics
extends Object

DistributedCmdMetrics has definitions for distributed command metrics and help methods.

Constructor Summary

Constructors

Constructor and Description
DistributedCmdMetrics()

Method Summary

Modifier and Type	Method and Description
static void	batchIncrementForCancelStatus(BatchedJobConfig config) Increment for Cancel status for batch job.
static void	batchIncrementForCompleteStatusWithRetry(BatchedJobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for batch config for complete status.
static void	batchIncrementForFailStatus(BatchedJobConfig config) Increment for Fail status for batch job.
static void	incrementFileCount(String jobType, long count) Increment by counts of files.
static void	incrementFileSize(String jobType, long fileSize) Increment by a fileSize.
static void	incrementForAllConfigsCancelStatus(JobConfig config) Increment for both batch and non-batch configs for Cancel status.
static void	incrementForAllConfigsCompleteStatus(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for both batch and non-batch configs for COMPLETE status.
static void	incrementForAllConfigsFailStatus(JobConfig config) Increment for both batch and non-batch configs for Fail status.
static void	incrementForCancelStatus(String jobType) Increment cancelled job count.
static void	incrementForCompleteStatusWithRetry(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for non-batch config for complete status.
static void	incrementForFailStatus(String jobType) Increment failed job count.
static void	incrementOperationCount(String jobType, long count) Increment by counts of operations.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedCmdMetrics

public DistributedCmdMetrics()

Method Detail

incrementOperationCount

public static void incrementOperationCount(String jobType,
                                           long count)

Increment by counts of operations.

Parameters:

jobType - the job type

count - the count of a stats counter

incrementFileCount

public static void incrementFileCount(String jobType,
                                      long count)

Increment by counts of files.

Parameters:

jobType - the job type

count - the count of a stats counter

incrementFileSize

public static void incrementFileSize(String jobType,
                                     long fileSize)

Increment by a fileSize.

Parameters:

jobType - the job type

fileSize - the file size to be added

incrementForFailStatus

public static void incrementForFailStatus(String jobType)

Increment failed job count.

Parameters:

jobType - job type

incrementForCancelStatus

public static void incrementForCancelStatus(String jobType)

Increment cancelled job count.

Parameters:

jobType - job type

incrementForCompleteStatusWithRetry

public static void incrementForCompleteStatusWithRetry(JobConfig config,
                                                       FileSystem fileSystem,
                                                       RetryPolicy retryPolicy)

Increment for non-batch config for complete status.

Parameters:

config - the job config

fileSystem - filesystem

retryPolicy - the retry policy used for retry operations

batchIncrementForCompleteStatusWithRetry

public static void batchIncrementForCompleteStatusWithRetry(BatchedJobConfig config,
                                                            FileSystem fileSystem,
                                                            RetryPolicy retryPolicy)

Increment for batch config for complete status.

Parameters:

config - the job config

fileSystem - filesystem

retryPolicy - the retry policy used for retry operations

batchIncrementForFailStatus

public static void batchIncrementForFailStatus(BatchedJobConfig config)

Increment for Fail status for batch job.

Parameters:

config - job config

batchIncrementForCancelStatus

public static void batchIncrementForCancelStatus(BatchedJobConfig config)

Increment for Cancel status for batch job.

Parameters:

config - job config

incrementForAllConfigsCompleteStatus

public static void incrementForAllConfigsCompleteStatus(JobConfig config,
                                                        FileSystem fileSystem,
                                                        RetryPolicy retryPolicy)

Increment for both batch and non-batch configs for COMPLETE status.

Parameters:

config - job config

fileSystem - filesystem

retryPolicy - the retry policy used for retry operations

incrementForAllConfigsCancelStatus

public static void incrementForAllConfigsCancelStatus(JobConfig config)

Increment for both batch and non-batch configs for Cancel status.

Parameters:

config -

incrementForAllConfigsFailStatus

public static void incrementForAllConfigsFailStatus(JobConfig config)

Increment for both batch and non-batch configs for Fail status.

Parameters:

config -