You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2017/02/15 09:43:57 UTC
phoenix git commit: PHOENIX-3675 Adding STDDEV_POP,
STDDEV_SAMP functions(Rajeshbabu)
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 <ra...@apache.org>
Authored: Wed Feb 15 15:26:49 2017 +0530
Committer: Rajeshbabu Chintaguntla <ra...@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) {