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 <sh...@uber.com>
Authored: Thu Mar 29 11:48:28 2018 -0700
Committer: Timo Walther <twal...@apache.org>
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..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

Reply via email to