diff options
Diffstat (limited to 'core/src/main/scala/spark/api/java/function/FlatMapFunction2.scala')
-rw-r--r-- | core/src/main/scala/spark/api/java/function/FlatMapFunction2.scala | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/core/src/main/scala/spark/api/java/function/FlatMapFunction2.scala b/core/src/main/scala/spark/api/java/function/FlatMapFunction2.scala deleted file mode 100644 index 4562884eb3..0000000000 --- a/core/src/main/scala/spark/api/java/function/FlatMapFunction2.scala +++ /dev/null @@ -1,13 +0,0 @@ -package spark.api.java.function - -import scala.reflect.ClassTag - -/** - * A function that takes two inputs and returns zero or more output records. - */ -abstract class FlatMapFunction2[A, B, C] extends Function2[A, B, java.lang.Iterable[C]] { - @throws(classOf[Exception]) - def call(a: A, b:B) : java.lang.Iterable[C] - - def elementType() : ClassTag[C] = ClassTag.Any.asInstanceOf[ClassTag[C]] -} |