[FLINK-3226] implement GroupReduce translation; enable tests for supp…

…orted operations Squashes the following commits: - Compute average as sum and count for byte, short and int type to avoid rounding errors - Move aggregation functions to org.apache.flink.table.runtime - Remove join-related changes - Change integer average aggregations to maintain sum and count - Long average uses a BigInteger sum
silenceland · Mar 18, 2016 · 7972426 · 7972426
1 parent b8028db
commit 7972426
Show file tree

Hide file tree

Showing 27 changed files with 360 additions and 676 deletions.
diff --git a/...-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TypeConverter.scala b/...-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TypeConverter.scala
@@ -135,7 +135,7 @@ object TypeConverter {
             logicalFieldTypes.head
           }
           else {
-            new TupleTypeInfo[Any](logicalFieldTypes.toArray:_*)
+            new TupleTypeInfo[Tuple](logicalFieldTypes.toArray:_*)
           }
         }
     }

diff --git a/...ble/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala b/...ble/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
diff --git a/...ble/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MinAggregate.scala b/...ble/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MinAggregate.scala
-Original file line number
+Diff line change
@@ Expand Up / @@ -135,7 +135,7 @@ object TypeConverter { @@
                 logicalFieldTypes.head
               }
               else {
-                new TupleTypeInfo[Any](logicalFieldTypes.toArray:_*)
+                new TupleTypeInfo[Tuple](logicalFieldTypes.toArray:_*)
               }
             }
         }
@@ Expand Down @@