Repository: flink Updated Branches: refs/heads/release-1.3 7a045f204 -> 98f4fad93
[FLINK-6598] [table] Remove unused parameter from DataStreamGroupAggregate. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/056d9553 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/056d9553 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/056d9553 Branch: refs/heads/release-1.3 Commit: 056d9553d713834d18c1b3490a6e3f106129a9ef Parents: 7a045f2 Author: sunjincheng121 <[email protected]> Authored: Tue May 16 19:08:11 2017 +0800 Committer: Fabian Hueske <[email protected]> Committed: Wed May 17 15:29:40 2017 +0200 ---------------------------------------------------------------------- .../table/plan/nodes/datastream/DataStreamGroupAggregate.scala | 3 --- .../plan/rules/datastream/DataStreamGroupAggregateRule.scala | 1 - 2 files changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/056d9553/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala index e5d8088..d54c04b 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala @@ -43,7 +43,6 @@ import org.slf4j.LoggerFactory * @param traitSet Trait set of the RelNode * @param inputNode The input RelNode of aggregation * @param namedAggregates List of calls to aggregate functions and their output field names - * @param rowRelDataType The type of the rows of the RelNode * @param inputSchema The type of the rows consumed by this RelNode * @param schema The type of the rows emitted by this RelNode * @param groupings The position (in the input Row) of the grouping keys @@ -53,7 +52,6 @@ class DataStreamGroupAggregate( traitSet: RelTraitSet, inputNode: RelNode, namedAggregates: Seq[CalcitePair[AggregateCall, String]], - rowRelDataType: RelDataType, schema: RowSchema, inputSchema: RowSchema, groupings: Array[Int]) @@ -79,7 +77,6 @@ class DataStreamGroupAggregate( traitSet, inputs.get(0), namedAggregates, - getRowType, schema, inputSchema, groupings) http://git-wip-us.apache.org/repos/asf/flink/blob/056d9553/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamGroupAggregateRule.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamGroupAggregateRule.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamGroupAggregateRule.scala index fd7619c..0b8e411 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamGroupAggregateRule.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamGroupAggregateRule.scala @@ -68,7 +68,6 @@ class DataStreamGroupAggregateRule traitSet, convInput, agg.getNamedAggCalls, - rel.getRowType, new RowSchema(rel.getRowType), new RowSchema(agg.getInput.getRowType), agg.getGroupSet.toArray)
