Repository: storm Updated Branches: refs/heads/1.x-branch 0c4fbacbd -> 3c7f11d80 refs/heads/master c73c17a3e -> 8295e5df5
STORM-2374: Storm Kafka Client Func Interface Must be Serializable Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a1148955 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a1148955 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a1148955 Branch: refs/heads/master Commit: a1148955f1b84bbfecb939dfa656ef5e1fc15acd Parents: 2833e30 Author: Hugo Louro <[email protected]> Authored: Wed Feb 22 15:03:16 2017 -0800 Committer: Hugo Louro <[email protected]> Committed: Wed Feb 22 15:03:16 2017 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/kafka/spout/Func.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/a1148955/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java index a631d96..0414533 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java @@ -17,10 +17,12 @@ */ package org.apache.storm.kafka.spout; +import java.io.Serializable; + /** * A simple interface to allow compatibility with non java 8 * code bases */ -public interface Func<V, R> { +public interface Func<V, R> extends Serializable { R apply(V record); }
