You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/06/06 13:58:22 UTC
[5/6] flink git commit: [streaming] Added throwing exceptions to
streaming functions
[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 <re...@gmail.com>
Authored: Thu Jun 4 15:21:39 2015 +0200
Committer: mbalassi <mb...@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;
}