flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/7] flink git commit: [hotfix] Remove unused ValueUtil
Date Mon, 14 Dec 2015 18:48:30 GMT
Repository: flink
Updated Branches:
  refs/heads/master 44eb58e08 -> 066913e23


[hotfix] Remove unused ValueUtil


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a26cced
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4a26cced
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4a26cced

Branch: refs/heads/master
Commit: 4a26cced238d276c2f9accc9ab226ddbdb3e895a
Parents: a8c4c48
Author: Stephan Ewen <sewen@apache.org>
Authored: Sun Dec 13 17:47:24 2015 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Mon Dec 14 17:44:19 2015 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/types/ValueUtil.java  | 66 --------------------
 1 file changed, 66 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/4a26cced/flink-core/src/main/java/org/apache/flink/types/ValueUtil.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/types/ValueUtil.java b/flink-core/src/main/java/org/apache/flink/types/ValueUtil.java
deleted file mode 100644
index 723906a..0000000
--- a/flink-core/src/main/java/org/apache/flink/types/ValueUtil.java
+++ /dev/null
@@ -1,66 +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.flink.types;
-
-/**
- * convert the java.lang type into a value type
- */
-public final class ValueUtil {
-	public static Value toFlinkValueType(Object java)  {
-		if (java == null) {
-			return NullValue.getInstance();
-		}
-		if (java.getClass() == java.lang.Boolean.class) {
-			return new BooleanValue(((java.lang.Boolean)java).booleanValue());
-		}
-		if (java.getClass() == java.lang.Integer.class) {
-			return new IntValue(((java.lang.Integer)java).intValue());
-		}
-		if (java.getClass() == java.lang.Byte.class) {
-			return new ByteValue(((java.lang.Byte)java).byteValue());
-		}
-		if (java.getClass() == java.lang.Character.class) {
-			return new CharValue(((java.lang.Character)java).charValue());
-		}
-		if (java.getClass() == java.lang.Double.class) {
-			return new DoubleValue(((java.lang.Double)java).doubleValue());
-		}
-		if (java.getClass() == java.lang.Float.class) {
-			return new FloatValue(((java.lang.Float)java).floatValue());
-		}
-		if (java.getClass() == java.lang.Long.class) {
-			return new LongValue(((java.lang.Long)java).longValue());
-		}
-		if (java.getClass() == java.lang.Short.class) {
-			return new ShortValue(((java.lang.Short)java).shortValue());
-		}
-		if (java.getClass() == java.lang.String.class) {
-			return new StringValue(((java.lang.String)java).toString());
-		}
-		throw new IllegalArgumentException("unsupported Java value");
-	}
-
-	/**
-	 * Private constructor to prevent instantiation.
-	 */
-	private ValueUtil() {
-		throw new RuntimeException();
-	}
-}


Mime
View raw message