diff --git a/ql/src/java/org/apache/hadoop/hive/ql/stats/ClientStatsPublisher.java b/ql/src/java/org/apache/hadoop/hive/ql/stats/ClientStatsPublisher.java index 2480f03cb8..b27e9f43f3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/stats/ClientStatsPublisher.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/stats/ClientStatsPublisher.java @@ -18,8 +18,14 @@ package org.apache.hadoop.hive.ql.stats; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + import java.util.Map; + +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ClientStatsPublisher { public void run(Map counterValues, String jobID); diff --git a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsAggregator.java b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsAggregator.java index dacf7a9f54..63fba6913b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsAggregator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsAggregator.java @@ -18,10 +18,14 @@ package org.apache.hadoop.hive.ql.stats; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + /** * An interface for any possible implementation for gathering statistics. */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public interface StatsAggregator { /** diff --git a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsCollectionContext.java b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsCollectionContext.java index b58dbf385e..f78e154d37 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsCollectionContext.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsCollectionContext.java @@ -23,8 +23,13 @@ import java.util.List; import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.exec.Task; + +@InterfaceAudience.Public +@InterfaceStability.Stable public class StatsCollectionContext { private final Configuration hiveConf; diff --git a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsPublisher.java b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsPublisher.java index 3631b83baa..7e01eff6d0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsPublisher.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/stats/StatsPublisher.java @@ -18,12 +18,16 @@ package org.apache.hadoop.hive.ql.stats; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + import java.util.Map; /** * An interface for any possible implementation for publishing statics. */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public interface StatsPublisher { /**