File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
streaming/src/main/scala/org/apache/spark/streaming/api/python Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff 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 () {}
You can’t perform that action at this time.
0 commit comments