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 long	getFileSize(String filePath, FileSystem fileSystem, RetryPolicy retryPolicy) get file size for a given filePath, return 0 if exceeding retries.
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, long count) 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, long count) Increment failed job count.

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

incrementForFailStatus

public static void incrementForFailStatus(String jobType,
                                          long count)

Increment failed job count.

Parameters:

jobType - job type

count - count to increment

incrementForCancelStatus

public static void incrementForCancelStatus(String jobType,
                                            long count)

Increment cancelled job count.

Parameters:

jobType - job type

count - count to increment

getFileSize

public static long getFileSize(String filePath,
                               FileSystem fileSystem,
                               RetryPolicy retryPolicy)

get file size for a given filePath, return 0 if exceeding retries.

Parameters:

filePath - file path

fileSystem - file system

retryPolicy - retry policy

Returns:

file size

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 - job config

incrementForAllConfigsFailStatus

public static void incrementForAllConfigsFailStatus(JobConfig config)

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

Parameters:

config - job config