flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject flink git commit: [FLINK-6733] Remove commented out AvgAggregationFunction.java
Date Wed, 20 Sep 2017 01:23:06 GMT
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 <Mikhail_Lipkovich@epam.com>
Authored: Thu Aug 31 17:38:31 2017 +0300
Committer: Kurt Young <kurt@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.");
-//			}
-//		}
-//	}
-//}


Mime
View raw message