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 37df73717c65d..990feacbdc598 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 @@ -144,4 +144,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