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/d4ff6b51 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d4ff6b51 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d4ff6b51 Branch: refs/heads/1.x-branch Commit: d4ff6b51f206e85e65bb5c4d06b4c28c828df174 Parents: d5f4c40 Author: Hugo Louro <[email protected]> Authored: Wed Feb 22 15:03:16 2017 -0800 Committer: Hugo Louro <[email protected]> Committed: Wed Feb 22 15:10:07 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/d4ff6b51/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); }
