@@ -34,7 +34,7 @@ import org.apache.spark.streaming.api.java._
3434/**
3535 * Interface for Python callback function with three arguments
3636 */
37- private [spark ] trait PythonRDDFunction {
37+ private [python ] trait PythonRDDFunction {
3838 // callback in Python
3939 def call (time : Long , rdds : JList [_]): JavaRDD [Array [Byte ]]
4040}
@@ -80,7 +80,7 @@ abstract class PythonDStream(parent: DStream[_], pfunc: PythonRDDFunction)
8080/**
8181 * Helper functions
8282 */
83- private [spark ] object PythonDStream {
83+ private [python ] object PythonDStream {
8484
8585 // convert Option[RDD[_]] to JavaRDD, handle null gracefully
8686 def wrapRDD (rdd : Option [RDD [_]]): JavaRDD [_] = {
@@ -129,7 +129,7 @@ private[spark] object PythonDStream {
129129 * If `reuse` is true and the result of the `func` is an PythonRDD, then it will cache it
130130 * as an template for future use, this can reduce the Python callbacks.
131131 */
132- private [spark ]
132+ private [python ]
133133class PythonTransformedDStream (parent : DStream [_], pfunc : PythonRDDFunction ,
134134 var reuse : Boolean = false )
135135 extends PythonDStream (parent, pfunc) {
@@ -168,7 +168,7 @@ class PythonTransformedDStream (parent: DStream[_], pfunc: PythonRDDFunction,
168168/**
169169 * Transformed from two DStreams in Python.
170170 */
171- private [spark ]
171+ private [python ]
172172class PythonTransformed2DStream (parent : DStream [_], parent2 : DStream [_],
173173 pfunc : PythonRDDFunction )
174174 extends DStream [Array [Byte ]] (parent.ssc) {
@@ -189,7 +189,7 @@ class PythonTransformed2DStream(parent: DStream[_], parent2: DStream[_],
189189/**
190190 * similar to StateDStream
191191 */
192- private [spark ]
192+ private [python ]
193193class PythonStateDStream (parent : DStream [Array [Byte ]], reduceFunc : PythonRDDFunction )
194194 extends PythonDStream (parent, reduceFunc) {
195195
@@ -210,7 +210,7 @@ class PythonStateDStream(parent: DStream[Array[Byte]], reduceFunc: PythonRDDFunc
210210/**
211211 * similar to ReducedWindowedDStream
212212 */
213- private [spark ]
213+ private [python ]
214214class PythonReducedWindowedDStream (parent : DStream [Array [Byte ]],
215215 preduceFunc : PythonRDDFunction ,
216216 pinvReduceFunc : PythonRDDFunction ,
0 commit comments