You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2017/09/20 01:23:06 UTC
flink git commit: [FLINK-6733] Remove commented out
AvgAggregationFunction.java
Repository: flink
Updated Branches:
refs/heads/master 25e9f83c4 -> 73a2443d4
[FLINK-6733] Remove commented out AvgAggregationFunction.java
This closes #4630.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73a2443d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/73a2443d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/73a2443d
Branch: refs/heads/master
Commit: 73a2443d467d872cdf354ed47bbf51ae816ba61e
Parents: 25e9f83
Author: Mikhail Lipkovich <Mi...@epam.com>
Authored: Thu Aug 31 17:38:31 2017 +0300
Committer: Kurt Young <ku...@apache.org>
Committed: Wed Sep 20 09:21:12 2017 +0800
----------------------------------------------------------------------
.../aggregation/AvgAggregationFunction.java | 211 -------------------
1 file changed, 211 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/73a2443d/flink-java/src/main/java/org/apache/flink/api/java/aggregation/AvgAggregationFunction.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/aggregation/AvgAggregationFunction.java b/flink-java/src/main/java/org/apache/flink/api/java/aggregation/AvgAggregationFunction.java
deleted file mode 100644
index 4760b92..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/aggregation/AvgAggregationFunction.java
+++ /dev/null
@@ -1,211 +0,0 @@
-package org.apache.flink.api.java.aggregation;
-/**
- * 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.flink.api.java.aggregation;
-//
-//
-//public abstract class AvgAggregationFunction<T> extends AggregationFunction<T> {
-// private static final long serialVersionUID = 1L;
-//
-//
-// @Override
-// public String toString() {
-// return "AVG";
-// }
-//
-// // --------------------------------------------------------------------------------------------
-//
-// public static final class ByteAvgAgg extends AvgAggregationFunction<Byte> {
-// private static final long serialVersionUID = 1L;
-//
-// private long sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Byte value) {
-// sum += value.byteValue();
-// count++;
-// }
-//
-// @Override
-// public Byte getAggregate() {
-// return (byte) (sum / count);
-// }
-// }
-//
-// public static final class ShortAvgAgg extends AvgAggregationFunction<Short> {
-// private static final long serialVersionUID = 1L;
-//
-// private long sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Short value) {
-// sum += value.shortValue();
-// count++;
-// }
-//
-// @Override
-// public Short getAggregate() {
-// return (short) (sum / count);
-// }
-// }
-//
-// public static final class IntAvgAgg extends AvgAggregationFunction<Integer> {
-// private static final long serialVersionUID = 1L;
-//
-// private long sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Integer value) {
-// sum += value.intValue();
-// count++;
-// }
-//
-// @Override
-// public Integer getAggregate() {
-// return (int) (sum / count);
-// }
-// }
-//
-// public static final class LongAvgAgg extends AvgAggregationFunction<Long> {
-// private static final long serialVersionUID = 1L;
-//
-// private long sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Long value) {
-// sum += value.longValue();
-// count++;
-// }
-//
-// @Override
-// public Long getAggregate() {
-// return sum / count;
-// }
-// }
-//
-// public static final class FloatAvgAgg extends AvgAggregationFunction<Float> {
-// private static final long serialVersionUID = 1L;
-//
-// private float sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0.0f;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Float value) {
-// sum += value.floatValue();
-// count++;
-// }
-//
-// @Override
-// public Float getAggregate() {
-// return sum / count;
-// }
-// }
-//
-// public static final class DoubleAvgAgg extends AvgAggregationFunction<Double> {
-// private static final long serialVersionUID = 1L;
-//
-// private double sum;
-// private long count;
-//
-// @Override
-// public void initializeAggregate() {
-// sum = 0.0;
-// count = 0;
-// }
-//
-// @Override
-// public void aggregate(Double value) {
-// sum += value.doubleValue();
-// count++;
-// }
-//
-// @Override
-// public Double getAggregate() {
-// return sum / count;
-// }
-// }
-//
-//
-// // --------------------------------------------------------------------------------------------
-//
-// public static final class AvgAggregationFunctionFactory implements AggregationFunctionFactory {
-// private static final long serialVersionUID = 1L;
-//
-// @SuppressWarnings("unchecked")
-// @Override
-// public <T> AggregationFunction<T> createAggregationFunction(Class<T> type) {
-// if (type == Long.class) {
-// return (AggregationFunction<T>) new LongAvgAgg();
-// }
-// else if (type == Integer.class) {
-// return (AggregationFunction<T>) new IntAvgAgg();
-// }
-// else if (type == Double.class) {
-// return (AggregationFunction<T>) new DoubleAvgAgg();
-// }
-// else if (type == Float.class) {
-// return (AggregationFunction<T>) new FloatAvgAgg();
-// }
-// else if (type == Byte.class) {
-// return (AggregationFunction<T>) new ByteAvgAgg();
-// }
-// else if (type == Short.class) {
-// return (AggregationFunction<T>) new ShortAvgAgg();
-// }
-// else {
-// throw new UnsupportedAggregationTypeException("The type " + type.getName() +
-// " has currently not supported for built-in average aggregations.");
-// }
-// }
-// }
-//}