You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/04/04 15:00:32 UTC
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 <sh...@uber.com>
Authored: Thu Mar 29 11:48:28 2018 -0700
Committer: Timo Walther <tw...@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