Skip to content

Commit 4afa390

Browse files
committed
clean up code
1 parent 67473a9 commit 4afa390

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,11 +116,13 @@ class PythonForeachDStream(
116116

117117
/**
118118
* This is a input stream just for the unitest. This is equivalent to a checkpointable,
119-
* replayable, reliable message queue like Kafka. It requires a sequence as input, and
120-
* returns the i_th element at the i_th batch under manual clock.
119+
* replayable, reliable message queue like Kafka. It requires a JArrayList input of JavaRDD,
120+
* and returns the i_th element at the i_th batch under manual clock.
121121
*/
122122

123-
class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[JavaRDD[Array[Byte]]])
123+
class PythonTestInputStream(
124+
ssc_ : JavaStreamingContext,
125+
inputRDDs: JArrayList[JavaRDD[Array[Byte]]])
124126
extends InputDStream[Array[Byte]](JavaStreamingContext.toStreamingContext(ssc_)) {
125127

126128
def start() {}

0 commit comments

Comments
 (0)