org.apache.spark.metrics.source

Class HiveCatalogMetrics

Object

org.apache.spark.metrics.source.HiveCatalogMetrics

public class HiveCatalogMetrics
extends Object

Metrics for access to the hive external catalog.

Constructor Summary

Constructors

Constructor and Description
HiveCatalogMetrics()

Method Summary

Modifier and Type	Method and Description
static void	incrementFetchedPartitions(int n)
static void	incrementFileCacheHits(int n)
static void	incrementFilesDiscovered(int n)
static void	incrementHiveClientCalls(int n)
static void	incrementParallelListingJobCount(int n)
static com.codahale.metrics.Counter	METRIC_FILE_CACHE_HITS() Tracks the total number of files served from the file status cache instead of discovered.
static com.codahale.metrics.Counter	METRIC_FILES_DISCOVERED() Tracks the total number of files discovered off of the filesystem by InMemoryFileIndex.
static com.codahale.metrics.Counter	METRIC_HIVE_CLIENT_CALLS() Tracks the total number of Hive client calls (e.g.
static com.codahale.metrics.Counter	METRIC_PARALLEL_LISTING_JOB_COUNT() Tracks the total number of Spark jobs launched for parallel file listing.
static com.codahale.metrics.Counter	METRIC_PARTITIONS_FETCHED() Tracks the total number of partition metadata entries fetched via the client api.
static com.codahale.metrics.MetricRegistry	metricRegistry()
static void	reset() Resets the values of all metrics to zero.
static String	sourceName()

Methods inherited from class Object

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

Constructor Detail

HiveCatalogMetrics

public HiveCatalogMetrics()

Method Detail

sourceName

public static String sourceName()

metricRegistry

public static com.codahale.metrics.MetricRegistry metricRegistry()

METRIC_PARTITIONS_FETCHED

public static com.codahale.metrics.Counter METRIC_PARTITIONS_FETCHED()

Tracks the total number of partition metadata entries fetched via the client api.

Returns:

(undocumented)

METRIC_FILES_DISCOVERED

public static com.codahale.metrics.Counter METRIC_FILES_DISCOVERED()

Tracks the total number of files discovered off of the filesystem by InMemoryFileIndex.

Returns:

(undocumented)

METRIC_FILE_CACHE_HITS

public static com.codahale.metrics.Counter METRIC_FILE_CACHE_HITS()

Tracks the total number of files served from the file status cache instead of discovered.

Returns:

(undocumented)

METRIC_HIVE_CLIENT_CALLS

public static com.codahale.metrics.Counter METRIC_HIVE_CLIENT_CALLS()

Tracks the total number of Hive client calls (e.g. to lookup a table).

Returns:

(undocumented)

METRIC_PARALLEL_LISTING_JOB_COUNT

public static com.codahale.metrics.Counter METRIC_PARALLEL_LISTING_JOB_COUNT()

Tracks the total number of Spark jobs launched for parallel file listing.

Returns:

(undocumented)

reset

public static void reset()

Resets the values of all metrics to zero. This is useful in tests.

incrementFetchedPartitions

public static void incrementFetchedPartitions(int n)

incrementFilesDiscovered

public static void incrementFilesDiscovered(int n)

incrementFileCacheHits

public static void incrementFileCacheHits(int n)

incrementHiveClientCalls

public static void incrementHiveClientCalls(int n)

incrementParallelListingJobCount

public static void incrementParallelListingJobCount(int n)