flink git commit: [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo
Repository: flink Updated Branches: refs/heads/release-1.5 4b10dd684 -> a298e6e4f [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo This closes #5794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a298e6e4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a298e6e4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a298e6e4 Branch: refs/heads/release-1.5 Commit: a298e6e4f81ec2cab4c86dd07f441eaebada4915 Parents: 4b10dd6 Author: Shuyi Chen Authored: Thu Mar 29 11:48:28 2018 -0700 Committer: Timo Walther Committed: Wed Apr 4 17:01:00 2018 +0200 -- .../calcite/sql/SqlGroupedWindowFunction.java | 136 --- 1 file changed, 136 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink/blob/a298e6e4/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java -- diff --git a/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java b/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java deleted file mode 100644 index 0f661e1..000 --- a/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java +++ /dev/null @@ -1,136 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to you under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.calcite.sql; - -import com.google.common.base.Preconditions; -import org.apache.calcite.sql.type.ReturnTypes; -import org.apache.calcite.sql.type.SqlOperandTypeChecker; -import org.apache.calcite.sql.type.SqlOperandTypeInference; -import org.apache.calcite.sql.type.SqlReturnTypeInference; -import org.apache.calcite.sql.validate.SqlMonotonicity; - -import com.google.common.collect.ImmutableList; - -import java.util.List; - -/* - * THIS FILE HAS BEEN COPIED FROM THE APACHE CALCITE PROJECT UNTIL CALCITE-2133 IS FIXED. - */ - -/** - * SQL function that computes keys by which rows can be partitioned and - * aggregated. - * - * Grouped window functions always occur in the GROUP BY clause. They often - * have auxiliary functions that access information about the group. For - * example, {@code HOP} is a group function, and its auxiliary functions are - * {@code HOP_START} and {@code HOP_END}. Here they are used in a streaming - * query: - * - * - * SELECT STREAM HOP_START(rowtime, INTERVAL '1' HOUR), - * HOP_END(rowtime, INTERVAL '1' HOUR), - * MIN(unitPrice) - * FROM Orders - * GROUP BY HOP(rowtime, INTERVAL '1' HOUR), productId - * - */ -public class SqlGroupedWindowFunction extends SqlFunction { - /** The grouped function, if this an auxiliary function; null otherwise. */ - public final SqlGroupedWindowFunction groupFunction; - - /** Creates a SqlGroupedWindowFunction. -* -* @param name Function name -* @param kind Kind -* @param groupFunction Group function, if this is an auxiliary; -* null, if this is a group function -* @param returnTypeInference Strategy to use for return type inference -* @param operandTypeInference Strategy to use for parameter type inference -* @param operandTypeChecker Strategy to use for parameter type checking -* @param category Categorization for function -*/ - public SqlGroupedWindowFunction(String name, SqlKind kind, - SqlGroupedWindowFunction groupFunction, - SqlReturnTypeInference returnTypeInference, - SqlOperandTypeInference operandTypeInference, - SqlOperandTypeChecker operandTypeChecker, SqlFunctionCategory category) { - super(name, kind, returnTypeInference, operandTypeInference, - operandTypeChecker, category); - this.groupFunction = groupFunction; - Preconditions.checkArgument(gro
flink git commit: [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo
Repository: flink Updated Branches: refs/heads/master a71b90318 -> 98a8b642f [FLINK-8509] [table] Remove SqlGroupedWindowFunction class from Flink repo This closes #5794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98a8b642 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/98a8b642 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/98a8b642 Branch: refs/heads/master Commit: 98a8b642f24c813a4929dfd780163778dc5bd010 Parents: a71b903 Author: Shuyi Chen Authored: Thu Mar 29 11:48:28 2018 -0700 Committer: Timo Walther Committed: Wed Apr 4 16:54:47 2018 +0200 -- .../calcite/sql/SqlGroupedWindowFunction.java | 136 --- 1 file changed, 136 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink/blob/98a8b642/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java -- diff --git a/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java b/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java deleted file mode 100644 index 0f661e1..000 --- a/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/SqlGroupedWindowFunction.java +++ /dev/null @@ -1,136 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to you under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.calcite.sql; - -import com.google.common.base.Preconditions; -import org.apache.calcite.sql.type.ReturnTypes; -import org.apache.calcite.sql.type.SqlOperandTypeChecker; -import org.apache.calcite.sql.type.SqlOperandTypeInference; -import org.apache.calcite.sql.type.SqlReturnTypeInference; -import org.apache.calcite.sql.validate.SqlMonotonicity; - -import com.google.common.collect.ImmutableList; - -import java.util.List; - -/* - * THIS FILE HAS BEEN COPIED FROM THE APACHE CALCITE PROJECT UNTIL CALCITE-2133 IS FIXED. - */ - -/** - * SQL function that computes keys by which rows can be partitioned and - * aggregated. - * - * Grouped window functions always occur in the GROUP BY clause. They often - * have auxiliary functions that access information about the group. For - * example, {@code HOP} is a group function, and its auxiliary functions are - * {@code HOP_START} and {@code HOP_END}. Here they are used in a streaming - * query: - * - * - * SELECT STREAM HOP_START(rowtime, INTERVAL '1' HOUR), - * HOP_END(rowtime, INTERVAL '1' HOUR), - * MIN(unitPrice) - * FROM Orders - * GROUP BY HOP(rowtime, INTERVAL '1' HOUR), productId - * - */ -public class SqlGroupedWindowFunction extends SqlFunction { - /** The grouped function, if this an auxiliary function; null otherwise. */ - public final SqlGroupedWindowFunction groupFunction; - - /** Creates a SqlGroupedWindowFunction. -* -* @param name Function name -* @param kind Kind -* @param groupFunction Group function, if this is an auxiliary; -* null, if this is a group function -* @param returnTypeInference Strategy to use for return type inference -* @param operandTypeInference Strategy to use for parameter type inference -* @param operandTypeChecker Strategy to use for parameter type checking -* @param category Categorization for function -*/ - public SqlGroupedWindowFunction(String name, SqlKind kind, - SqlGroupedWindowFunction groupFunction, - SqlReturnTypeInference returnTypeInference, - SqlOperandTypeInference operandTypeInference, - SqlOperandTypeChecker operandTypeChecker, SqlFunctionCategory category) { - super(name, kind, returnTypeInference, operandTypeInference, - operandTypeChecker, category); - this.groupFunction = groupFunction; - Preconditions.checkArgument(groupFunction