[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 <reckone...@gmail.com> Authored: Thu Jun 4 15:21:39 2015 +0200 Committer: mbalassi <mbala...@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; }
