HIVE-11480: CBO: Calcite Operator To Hive Operator (Calcite Return Path): char/varchar as input to GenericUDAF (Pengcheng Xiong, reviewed by Jesus Camacho Rodriguez)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/0140df74 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/0140df74 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/0140df74 Branch: refs/heads/hbase-metastore Commit: 0140df748f6714cc327132f008a13f6af5e41397 Parents: c4ceefb Author: Pengcheng Xiong <pxi...@apache.org> Authored: Wed Aug 12 10:43:35 2015 -0700 Committer: Pengcheng Xiong <pxi...@apache.org> Committed: Wed Aug 12 10:43:35 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java | 2 ++ .../org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java | 2 ++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/0140df74/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java index 159a2fe..071884c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStd.java @@ -55,6 +55,8 @@ public class GenericUDAFStd extends GenericUDAFVariance { case FLOAT: case DOUBLE: case STRING: + case VARCHAR: + case CHAR: case TIMESTAMP: case DECIMAL: return new GenericUDAFStdEvaluator(); http://git-wip-us.apache.org/repos/asf/hive/blob/0140df74/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java index 3545390..2950605 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFVariance.java @@ -72,6 +72,8 @@ public class GenericUDAFVariance extends AbstractGenericUDAFResolver { case FLOAT: case DOUBLE: case STRING: + case VARCHAR: + case CHAR: case TIMESTAMP: case DECIMAL: return new GenericUDAFVarianceEvaluator();
