From bebb3f3123040a3d48ea46faa9b02a5bf2a837c7 Mon Sep 17 00:00:00 2001 From: giwa Date: Wed, 20 Aug 2014 19:44:05 -0700 Subject: [PATCH] remove the last brank line --- .../org/apache/spark/streaming/api/python/PythonDStream.scala | 2 +- .../apache/spark/streaming/api/python/PythonRDDFunction.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala index 3c9fff6f4bf5c..717592dbf8bf9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala @@ -198,4 +198,4 @@ class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[J } val asJavaDStream = JavaDStream.fromDStream(this) -} +} \ No newline at end of file diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java index 84d092ea0048f..eacff4b0e6006 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java @@ -9,4 +9,4 @@ */ public interface PythonRDDFunction { JavaRDD call(JavaRDD rdd, long time); -} +} \ No newline at end of file