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 <sh...@uber.com> Authored: Thu Mar 29 11:48:28 2018 -0700 Committer: Timo Walther <twal...@apache.org> 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..0000000 --- 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. - * - * <p>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: - * - * <blockquote><pre> - * 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 - * </pre></blockquote> - */ -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 == null - || groupFunction.groupFunction == null); - } - - @Deprecated // to be removed before 2.0 - public SqlGroupedWindowFunction(String name, SqlKind kind, - SqlGroupedWindowFunction groupFunction, - SqlOperandTypeChecker operandTypeChecker) { - this(name, kind, groupFunction, ReturnTypes.ARG0, null, operandTypeChecker, - SqlFunctionCategory.SYSTEM); - } - - @Deprecated // to be removed before 2.0 - public SqlGroupedWindowFunction(SqlKind kind, - SqlGroupedWindowFunction groupFunction, - SqlOperandTypeChecker operandTypeChecker) { - this(kind.name(), kind, groupFunction, ReturnTypes.ARG0, null, - operandTypeChecker, SqlFunctionCategory.SYSTEM); - } - - /** Creates an auxiliary function from this grouped window function. - * - * @param kind Kind; also determines function name - */ - public SqlGroupedWindowFunction auxiliary(SqlKind kind) { - return auxiliary(kind.name(), kind); - } - - /** Creates an auxiliary function from this grouped window function. - * - * @param name Function name - * @param kind Kind - */ - public SqlGroupedWindowFunction auxiliary(String name, SqlKind kind) { - return new SqlGroupedWindowFunction(name, kind, this, getOperandTypeChecker()); - } - - /** Returns a list of this grouped window function's auxiliary functions. */ - public List<SqlGroupedWindowFunction> getAuxiliaryFunctions() { - return ImmutableList.of(); - } - - @Override public boolean isGroup() { - // Auxiliary functions are not group functions - return groupFunction == null; - } - - @Override public boolean isGroupAuxiliary() { - return groupFunction != null; - } - - @Override public SqlMonotonicity getMonotonicity(SqlOperatorBinding call) { - // Monotonic iff its first argument is, but not strict. - // - // Note: This strategy happens to works for all current group functions - // (HOP, TUMBLE, SESSION). When there are exceptions to this rule, we'll - // make the method abstract. - return call.getOperandMonotonicity(0).unstrict(); - } -} - -// End SqlGroupedWindowFunction.java
