Repository: phoenix Updated Branches: refs/heads/calcite 1998fb7a0 -> 3c750bbec
PHOENIX-3675 Adding STDDEV_POP, STDDEV_SAMP functions(Rajeshbabu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/3c750bbe Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/3c750bbe Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/3c750bbe Branch: refs/heads/calcite Commit: 3c750bbec316b487577b332a5fdd1a14fca13e05 Parents: 1998fb7 Author: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Authored: Wed Feb 15 15:26:49 2017 +0530 Committer: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Committed: Wed Feb 15 15:26:49 2017 +0530 ---------------------------------------------------------------------- .../org/apache/phoenix/calcite/CalciteUtils.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c750bbe/phoenix-core/src/main/java/org/apache/phoenix/calcite/CalciteUtils.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/calcite/CalciteUtils.java b/phoenix-core/src/main/java/org/apache/phoenix/calcite/CalciteUtils.java index d1ca972..c9c8102 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/calcite/CalciteUtils.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/calcite/CalciteUtils.java @@ -107,6 +107,8 @@ import org.apache.phoenix.expression.function.PowerFunction; import org.apache.phoenix.expression.function.RoundDecimalExpression; import org.apache.phoenix.expression.function.RoundTimestampExpression; import org.apache.phoenix.expression.function.SqrtFunction; +import org.apache.phoenix.expression.function.StddevPopFunction; +import org.apache.phoenix.expression.function.StddevSampFunction; import org.apache.phoenix.expression.function.SumAggregateFunction; import org.apache.phoenix.expression.function.TrimFunction; import org.apache.phoenix.expression.function.UDFExpression; @@ -1009,6 +1011,20 @@ public class CalciteUtils { return new MinAggregateFunction(args, null); } }); + FUNCTION_MAP.put("STDDEV_POP", new FunctionFactory() { + @Override + public FunctionExpression newFunction(SqlFunction sqlFunc, + List<Expression> args) { + return new StddevPopFunction(args); + } + }); + FUNCTION_MAP.put("STDDEV_SAMP", new FunctionFactory() { + @Override + public FunctionExpression newFunction(SqlFunction sqlFunc, + List<Expression> args) { + return new StddevSampFunction(args); + } + }); } private static List<Expression> convertChildren(RexCall call, PhoenixRelImplementor implementor) {
