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)