Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4585
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142903359
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1412,23 +1412,12 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142664563
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1410,6 +1410,26 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142667720
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala
---
@@ -92,6 +92,63 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142667939
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1410,6 +1410,26 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142664211
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,159 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r142665388
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala
---
@@ -92,6 +92,63 @@ class SqlITCase
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141576017
--- Diff: docs/dev/table/sql.md ---
@@ -746,6 +746,7 @@ The SQL runtime is built on top of Flink's DataSet and
DataStream APIs. Internal
|
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141576005
--- Diff: docs/dev/table/sql.md ---
@@ -2107,6 +2108,17 @@ VAR_SAMP(value)
Returns the sample variance (square of the sample standard
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141517953
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141507401
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141507197
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141507177
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141494189
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141494139
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141485942
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1414,8 +1414,29 @@ object
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141485981
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1414,8 +1414,29 @@ object
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141449807
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141352765
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141260762
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141260601
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141256073
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141256026
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141255931
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141255917
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141100624
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141103652
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141095159
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141096324
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141104254
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141106084
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141093589
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r14367
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1414,8 +1414,29 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141096269
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141105482
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141096297
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141097263
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141102418
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141099803
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141093104
--- Diff: docs/dev/table/sql.md ---
@@ -746,6 +746,7 @@ The SQL runtime is built on top of Flink's DataSet and
DataStream APIs. Internal
|
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r14022
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1414,8 +1414,29 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141113194
--- Diff: docs/dev/table/sql.md ---
@@ -2107,6 +2108,17 @@ VAR_SAMP(value)
Returns the sample variance (square of the sample standard
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141097303
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141097202
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r141112340
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1414,8 +1414,29 @@ object
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140176626
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140167679
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140159387
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140159053
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089533
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ *
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089018
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140083074
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140024187
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140022994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140026944
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140009815
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140025368
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ *
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r139237307
--- Diff: flink-core/pom.xml ---
@@ -80,6 +80,13 @@ under the License.
+
+
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r139237144
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -211,6 +218,14 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r13586
--- Diff: flink-core/pom.xml ---
@@ -80,6 +80,13 @@ under the License.
+
+
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r138889015
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -211,6 +218,14 @@ class
61 matches
Mail list logo
