Package 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 Details

    • HiveCatalogMetrics

      public HiveCatalogMetrics()

  • Method Details

    • 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)