flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject [5/6] flink git commit: [streaming] Added throwing exceptions to streaming functions
Date Sat, 06 Jun 2015 11:58:22 GMT
[streaming] Added throwing exceptions to streaming functions


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

Branch: refs/heads/master
Commit: 59a2297c3ce25859e11c06fa4c5c2dd22b0cb2ea
Parents: 03ae80d
Author: Gábor Hermann <reckoner42@gmail.com>
Authored: Thu Jun 4 15:21:39 2015 +0200
Committer: mbalassi <mbalassi@apache.org>
Committed: Sat Jun 6 13:56:54 2015 +0200

----------------------------------------------------------------------
 .../flink/streaming/api/functions/co/CoFlatMapFunction.java  | 4 ++--
 .../flink/streaming/api/functions/co/CoMapFunction.java      | 4 ++--
 .../flink/streaming/api/functions/co/CoReduceFunction.java   | 8 ++++----
 .../flink/streaming/api/functions/co/CoWindowFunction.java   | 2 +-
 .../flink/streaming/api/functions/sink/SinkFunction.java     | 2 +-
 5 files changed, 10 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/59a2297c/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
index 1137dda..ae11cd9 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
@@ -36,7 +36,7 @@ import org.apache.flink.util.Collector;
  */
 public interface CoFlatMapFunction<IN1, IN2, OUT> extends Function, Serializable {
 
-	public void flatMap1(IN1 value, Collector<OUT> out) throws Exception;
+	void flatMap1(IN1 value, Collector<OUT> out) throws Exception;
 
-	public void flatMap2(IN2 value, Collector<OUT> out) throws Exception;
+	void flatMap2(IN2 value, Collector<OUT> out) throws Exception;
 }

http://git-wip-us.apache.org/repos/asf/flink/blob/59a2297c/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java
index 67ab672..a545282 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java
@@ -35,7 +35,7 @@ import org.apache.flink.api.common.functions.Function;
  */
 public interface CoMapFunction<IN1, IN2, OUT> extends Function, Serializable {
 
-	public OUT map1(IN1 value);
+	OUT map1(IN1 value) throws Exception;
 
-	public OUT map2(IN2 value);
+	OUT map2(IN2 value) throws Exception;
 }

http://git-wip-us.apache.org/repos/asf/flink/blob/59a2297c/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoReduceFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoReduceFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoReduceFunction.java
index 4342dfd..9518d4b 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoReduceFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoReduceFunction.java
@@ -67,7 +67,7 @@ public interface CoReduceFunction<IN1, IN2, OUT> extends Function,
Serializable
 	 *             This method may throw exceptions. Throwing an exception will
 	 *             cause the operation to fail and may trigger recovery.
 	 */
-	public IN1 reduce1(IN1 value1, IN1 value2);
+	IN1 reduce1(IN1 value1, IN1 value2) throws Exception;
 
 	/**
 	 * The core method of ReduceFunction, combining two values of the second
@@ -85,7 +85,7 @@ public interface CoReduceFunction<IN1, IN2, OUT> extends Function,
Serializable
 	 *             This method may throw exceptions. Throwing an exception will
 	 *             cause the operation to fail and may trigger recovery.
 	 */
-	public IN2 reduce2(IN2 value1, IN2 value2);
+	IN2 reduce2(IN2 value1, IN2 value2) throws Exception;
 
 	/**
 	 * Maps the reduced first input to the output type.
@@ -94,7 +94,7 @@ public interface CoReduceFunction<IN1, IN2, OUT> extends Function,
Serializable
 	 *            Type of the first input.
 	 * @return the output type.
 	 */
-	public OUT map1(IN1 value);
+	OUT map1(IN1 value) throws Exception;
 
 	/**
 	 * Maps the reduced second input to the output type.
@@ -103,5 +103,5 @@ public interface CoReduceFunction<IN1, IN2, OUT> extends Function,
Serializable
 	 *            Type of the second input.
 	 * @return the output type.
 	 */
-	public OUT map2(IN2 value);
+	OUT map2(IN2 value) throws Exception;
 }

http://git-wip-us.apache.org/repos/asf/flink/blob/59a2297c/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoWindowFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoWindowFunction.java
index 1e8d03c..1ae5137 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoWindowFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/co/CoWindowFunction.java
@@ -26,5 +26,5 @@ import org.apache.flink.util.Collector;
 
 public interface CoWindowFunction<IN1, IN2, O> extends Function, Serializable {
 
-	public void coWindow(List<IN1> first, List<IN2> second, Collector<O> out)
throws Exception;
+	void coWindow(List<IN1> first, List<IN2> second, Collector<O> out) throws
Exception;
 }

http://git-wip-us.apache.org/repos/asf/flink/blob/59a2297c/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
index 9c7ceeb..21308ed 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
@@ -34,5 +34,5 @@ public interface SinkFunction<IN> extends Function, Serializable {
 	 * @param value The input record.
 	 * @throws Exception
 	 */
-	public void invoke(IN value) throws Exception;
+	void invoke(IN value) throws Exception;
 }


Mime
View raw message