diff options
Diffstat (limited to 'core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java')
-rw-r--r-- | core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java b/core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java index 57fd0a7a80..576087b6f4 100644 --- a/core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java +++ b/core/src/main/java/org/apache/spark/api/java/function/DoubleFlatMapFunction.java @@ -18,10 +18,11 @@ package org.apache.spark.api.java.function; import java.io.Serializable; +import java.util.Iterator; /** * A function that returns zero or more records of type Double from each input record. */ public interface DoubleFlatMapFunction<T> extends Serializable { - public Iterable<Double> call(T t) throws Exception; + Iterator<Double> call(T t) throws Exception; } |