Repository: hive Updated Branches: refs/heads/master 8fe6e41af -> 330c62f84
HIVE-17132: Add InterfaceAudience and InterfaceStability annotations for UDF APIs (Sahil Takiar, reviewed by Ashutosh Chauhan) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/330c62f8 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/330c62f8 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/330c62f8 Branch: refs/heads/master Commit: 330c62f842cd145e559e83fa00ea26bdcbd7f7d3 Parents: 8fe6e41 Author: Sahil Takiar <takiar.sa...@gmail.com> Authored: Tue Aug 22 12:51:03 2017 -0700 Committer: Sahil Takiar <stak...@cloudera.com> Committed: Tue Aug 22 12:51:46 2017 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java | 5 +++++ .../java/org/apache/hadoop/hive/ql/exec/MapredContext.java | 2 ++ ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java | 3 +++ .../org/apache/hadoop/hive/ql/exec/UDFArgumentException.java | 4 ++++ .../hadoop/hive/ql/exec/UDFArgumentLengthException.java | 5 +++++ .../apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java | 6 +++++- .../org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java | 1 + .../org/apache/hadoop/hive/ql/metadata/HiveException.java | 5 ++++- .../org/apache/hadoop/hive/ql/parse/SemanticException.java | 5 ++++- .../org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java | 4 ++++ .../hive/ql/udf/generic/AbstractGenericUDAFResolver.java | 1 + .../org/apache/hadoop/hive/ql/udf/generic/Collector.java | 4 ++++ .../hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java | 8 ++++++++ .../hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java | 4 ++++ .../hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java | 1 + .../org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java | 6 ++++++ .../org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java | 5 ++++- .../serde2/objectinspector/ObjectInspectorConverters.java | 4 ++++ .../serde2/objectinspector/PrimitiveObjectInspector.java | 4 ++++ 19 files changed, 73 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java index a9af71a..536060e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Description.java @@ -18,6 +18,9 @@ package org.apache.hadoop.hive.ql.exec; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; @@ -25,6 +28,8 @@ import java.lang.annotation.RetentionPolicy; * Description. * */ +@InterfaceAudience.Public +@InterfaceStability.Stable @Retention(RetentionPolicy.RUNTIME) public @interface Description { String value() default "_FUNC_ is undocumented"; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/MapredContext.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapredContext.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapredContext.java index 7d51658..c2ae4d7 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapredContext.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapredContext.java @@ -24,6 +24,8 @@ import java.lang.reflect.Method; import java.util.ArrayList; import java.util.List; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.hadoop.hive.conf.HiveConf; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java index f8bc889..f2b4009 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDF.java @@ -52,7 +52,10 @@ import org.apache.hadoop.hive.ql.udf.UDFType; * * @see Description * @see UDFType + * + * @deprecated use {@link org.apache.hadoop.hive.ql.udf.generic.GenericUDF} */ +@Deprecated @UDFType(deterministic = true) public class UDF { http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentException.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentException.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentException.java index de2d1d9..df738d0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentException.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentException.java @@ -25,6 +25,8 @@ import java.util.Collections; import java.util.Comparator; import java.util.List; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.parse.SemanticException; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorUtils; import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; @@ -32,6 +34,8 @@ import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; /** * exception class, thrown when udf argument have something wrong. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class UDFArgumentException extends SemanticException { public UDFArgumentException() { http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentLengthException.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentLengthException.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentLengthException.java index 5ce2d5e..1a5bd9b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentLengthException.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentLengthException.java @@ -18,9 +18,14 @@ package org.apache.hadoop.hive.ql.exec; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + /** * exception class, thrown when udf arguments have wrong length. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class UDFArgumentLengthException extends UDFArgumentException { public UDFArgumentLengthException(String message) { super(message); http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java index 70a9296..8f8cc93 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFArgumentTypeException.java @@ -18,10 +18,14 @@ package org.apache.hadoop.hive.ql.exec; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; + /** * exception class, thrown when udf arguments have wrong types. */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public class UDFArgumentTypeException extends UDFArgumentException { int argumentId; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java index 4a6f0de..84cfc04 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/UDFMethodResolver.java @@ -36,6 +36,7 @@ import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; * simply have to extend UDFBaseNumericOp class. For the default resolution the * UDF implementation simply needs to extend the UDF class. */ +@Deprecated public interface UDFMethodResolver { /** http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveException.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveException.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveException.java index a23d8c0..e756445 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveException.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveException.java @@ -18,12 +18,15 @@ package org.apache.hadoop.hive.ql.metadata; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.ErrorMsg; /** * Generic exception class for Hive. */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public class HiveException extends Exception { /** * Standard predefined message with error code and possibly SQL State, etc. http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticException.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticException.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticException.java index cac5582..0a5f9e1 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticException.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticException.java @@ -18,13 +18,16 @@ package org.apache.hadoop.hive.ql.parse; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.ErrorMsg; import org.apache.hadoop.hive.ql.metadata.HiveException; /** * Exception from SemanticAnalyzer. */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public class SemanticException extends HiveException { private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java b/ql/src/java/org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java index 346abe3..b9a3053 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/plan/ptf/WindowFrameDef.java @@ -18,9 +18,13 @@ package org.apache.hadoop.hive.ql.plan.ptf; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.ql.parse.WindowingSpec.WindowType; +@InterfaceAudience.Public +@InterfaceStability.Stable public class WindowFrameDef { private WindowType windowType; private BoundaryDef start; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDAFResolver.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDAFResolver.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDAFResolver.java index 4d4e61d..f104891 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDAFResolver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDAFResolver.java @@ -30,6 +30,7 @@ import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; * <tt>GenericUDAFParameterInfo</tt> interface. * */ +@Deprecated public abstract class AbstractGenericUDAFResolver implements GenericUDAFResolver2 { http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/Collector.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/Collector.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/Collector.java index c73f2de..f58c23d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/Collector.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/Collector.java @@ -18,11 +18,15 @@ package org.apache.hadoop.hive.ql.udf.generic; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.metadata.HiveException; /** * Collector gets data from a source. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public interface Collector { /** * Other classes will call collect() with the data that it has. http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java index 3a98276..f873011 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEvaluator.java @@ -24,6 +24,8 @@ import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.util.List; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.exec.MapredContext; import org.apache.hadoop.hive.ql.exec.PTFPartition; import org.apache.hadoop.hive.ql.metadata.HiveException; @@ -46,9 +48,13 @@ import org.apache.hive.common.util.AnnotationUtils; * signature - for example, it's easy to write a GenericUDAF that accepts * array<int>, array<array<int>> and so on (arbitrary levels of nesting). */ +@InterfaceAudience.Public +@InterfaceStability.Stable @UDFType(deterministic = true) public abstract class GenericUDAFEvaluator implements Closeable { + @InterfaceAudience.Public + @InterfaceStability.Stable @Retention(RetentionPolicy.RUNTIME) public static @interface AggregationType { boolean estimable() default false; @@ -151,6 +157,8 @@ public abstract class GenericUDAFEvaluator implements Closeable { public static interface AggregationBuffer { }; + @InterfaceAudience.Public + @InterfaceStability.Stable public static abstract class AbstractAggregationBuffer implements AggregationBuffer { /** * Estimate the size of memory which is occupied by aggregation buffer. http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java index 675d9f3..01ea59f 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFParameterInfo.java @@ -17,6 +17,8 @@ */ package org.apache.hadoop.hive.ql.udf.generic; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector; import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; @@ -40,6 +42,8 @@ import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; * data bound to parameter types for <tt>DISTINCT</tt> implementation is * handled by the framework and not the <tt>COUNT</tt> UDAF implementation. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public interface GenericUDAFParameterInfo { /** http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java index d66b29a..b0489e3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFResolver2.java @@ -37,6 +37,7 @@ import org.apache.hadoop.hive.ql.parse.SemanticException; * data bound to parameter types for <tt>DISTINCT</tt> implementation is * handled by the framework and not the <tt>COUNT</tt> UDAF implementation. */ +@Deprecated @SuppressWarnings("deprecation") public interface GenericUDAFResolver2 extends GenericUDAFResolver { http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java index 6b67dea..0898de6 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDF.java @@ -24,6 +24,8 @@ import java.sql.Timestamp; import java.text.ParseException; import java.util.Date; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.exec.FunctionRegistry; import org.apache.hadoop.hive.ql.exec.MapredContext; import org.apache.hadoop.hive.ql.exec.UDFArgumentException; @@ -64,6 +66,8 @@ import org.apache.hive.common.util.DateUtils; * array<int>, array<array<int>> and so on (arbitrary levels of nesting). 4. It * can do short-circuit evaluations using DeferedObject. */ +@InterfaceAudience.Public +@InterfaceStability.Stable @UDFType(deterministic = true) public abstract class GenericUDF implements Closeable { @@ -74,6 +78,8 @@ public abstract class GenericUDF implements Closeable { * A Defered Object allows us to do lazy-evaluation and short-circuiting. * GenericUDF use DeferedObject to pass arguments. */ + @InterfaceAudience.Public + @InterfaceStability.Stable public static interface DeferredObject { void prepare(int version) throws HiveException; Object get() throws HiveException; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java index a93a264..fa74a52 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTF.java @@ -20,6 +20,8 @@ package org.apache.hadoop.hive.ql.udf.generic; import java.util.List; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.ql.exec.MapredContext; import org.apache.hadoop.hive.ql.exec.UDFArgumentException; import org.apache.hadoop.hive.ql.metadata.HiveException; @@ -33,7 +35,8 @@ import org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector; * Generates a variable number of output rows for a single input row. Useful for * explode(array)... */ - +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class GenericUDTF { Collector collector = null; http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java ---------------------------------------------------------------------- diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java index ca96e33..7025ebf 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorConverters.java @@ -22,6 +22,8 @@ import java.util.ArrayList; import java.util.List; import java.util.Map; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.serde2.objectinspector.primitive.JavaStringObjectInspector; import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorConverter; import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory; @@ -54,6 +56,8 @@ public final class ObjectInspectorConverters { /** * A converter which will convert objects with one ObjectInspector to another. */ + @InterfaceAudience.Public + @InterfaceStability.Stable public static interface Converter { Object convert(Object input); } http://git-wip-us.apache.org/repos/asf/hive/blob/330c62f8/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/PrimitiveObjectInspector.java ---------------------------------------------------------------------- diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/PrimitiveObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/PrimitiveObjectInspector.java index b037540..f95dd37 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/PrimitiveObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/PrimitiveObjectInspector.java @@ -17,6 +17,8 @@ */ package org.apache.hadoop.hive.serde2.objectinspector; +import org.apache.hadoop.hive.common.classification.InterfaceAudience; +import org.apache.hadoop.hive.common.classification.InterfaceStability; import org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo; @@ -24,6 +26,8 @@ import org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo; * PrimitiveObjectInspector. * */ +@InterfaceAudience.Public +@InterfaceStability.Stable public interface PrimitiveObjectInspector extends ObjectInspector { /**
