This is an automated email from the ASF dual-hosted git repository. myui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-hivemall.git
commit 5afa926de99181827e205a4192e97c2b5f4dcad9 Author: Makoto Yui <[email protected]> AuthorDate: Wed Feb 6 17:16:24 2019 +0900 Added usages --- .../java/hivemall/tools/array/ArrayAvgGenericUDAF.java | 17 ++++++++++++++++- .../main/java/hivemall/tools/array/ArraySumUDAF.java | 16 +++++++++++++++- 2 files changed, 31 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/hivemall/tools/array/ArrayAvgGenericUDAF.java b/core/src/main/java/hivemall/tools/array/ArrayAvgGenericUDAF.java index caaf84e..ad9c39a 100644 --- a/core/src/main/java/hivemall/tools/array/ArrayAvgGenericUDAF.java +++ b/core/src/main/java/hivemall/tools/array/ArrayAvgGenericUDAF.java @@ -22,6 +22,7 @@ import static org.apache.hadoop.hive.ql.util.JavaDataModel.JAVA64_ARRAY_META; import static org.apache.hadoop.hive.ql.util.JavaDataModel.JAVA64_REF; import static org.apache.hadoop.hive.ql.util.JavaDataModel.PRIMITIVES1; import static org.apache.hadoop.hive.ql.util.JavaDataModel.PRIMITIVES2; + import hivemall.utils.hadoop.HiveUtils; import hivemall.utils.hadoop.WritableUtils; @@ -57,8 +58,22 @@ import org.apache.hadoop.hive.serde2.typeinfo.TypeInfo; import org.apache.hadoop.io.FloatWritable; import org.apache.hadoop.io.IntWritable; +// @formatter:off @Description(name = "array_avg", value = "_FUNC_(array<number>) - Returns an array<double>" - + " in which each element is the mean of a set of numbers") + + " in which each element is the mean of a set of numbers", + extended = "WITH input as (\n" + + " select array(1.0, 2.0, 3.0) as nums\n" + + " UNION ALL\n" + + " select array(2.0, 3.0, 4.0) as nums\n" + + ")\n" + + "select\n" + + " array_avg(nums)\n" + + "from\n" + + " input;\n" + + "\n" + + "[\"1.5\",\"2.5\",\"3.5\"]" + ) +// @formatter:on public final class ArrayAvgGenericUDAF extends AbstractGenericUDAFResolver { @Override diff --git a/core/src/main/java/hivemall/tools/array/ArraySumUDAF.java b/core/src/main/java/hivemall/tools/array/ArraySumUDAF.java index 8a47957..a1431c4 100644 --- a/core/src/main/java/hivemall/tools/array/ArraySumUDAF.java +++ b/core/src/main/java/hivemall/tools/array/ArraySumUDAF.java @@ -31,9 +31,23 @@ import org.apache.hadoop.hive.ql.exec.UDAFEvaluator; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.serde2.io.DoubleWritable; +//@formatter:off @SuppressWarnings("deprecation") @Description(name = "array_sum", value = "_FUNC_(array<number>) - Returns an array<double>" - + " in which each element is summed up") + + " in which each element is summed up", + extended = "WITH input as (\n" + + " select array(1.0, 2.0, 3.0) as nums\n" + + " UNION ALL\n" + + " select array(2.0, 3.0, 4.0) as nums\n" + + ")\n" + + "select\n" + + " array_sum(nums)\n" + + "from\n" + + " input;\n" + + "\n" + + "[\"3.0\",\"5.0\",\"7.0\"]" + ) +// @formatter:on public final class ArraySumUDAF extends UDAF { public ArraySumUDAF() {}
