diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 23:59:45 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 23:59:45 -0800 |
commit | b4eb24de9692d05357766b8159ab4d5ec17f89da (patch) | |
tree | b1a05557b12cc61d337f7f5f57651b7a9c0f6fa5 /streaming | |
parent | d853aa9658a87d644d483b1fa9d41c29e3ac0673 (diff) | |
download | spark-b4eb24de9692d05357766b8159ab4d5ec17f89da.tar.gz spark-b4eb24de9692d05357766b8159ab4d5ec17f89da.tar.bz2 spark-b4eb24de9692d05357766b8159ab4d5ec17f89da.zip |
Updated streaming programming guide with Java API info, and comments from Patrick.
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala | 4 | ||||
-rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala | 1 |
2 files changed, 2 insertions, 3 deletions
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala index 51efe6cae8..4d93f0a5f7 100644 --- a/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala +++ b/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala @@ -17,9 +17,7 @@ import spark.RDD * * This class contains the basic operations available on all DStreams, such as `map`, `filter` and * `window`. In addition, [[spark.streaming.api.java.JavaPairDStream]] contains operations available - * only on DStreams of key-value pairs, such as `groupByKeyAndWindow` and `join`. These operations - * are automatically available on any DStream of the right type (e.g., DStream[(Int, Int)] through - * implicit conversions when `spark.streaming.StreamingContext._` is imported. + * only on DStreams of key-value pairs, such as `groupByKeyAndWindow` and `join`. * * DStreams internally is characterized by a few basic properties: * - A list of other DStreams that the DStream depends on diff --git a/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala index 024bf3bea4..6b310bc0b6 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala @@ -7,6 +7,7 @@ import scala.collection.mutable.Queue import scala.collection.mutable.ArrayBuffer import spark.streaming.{Time, StreamingContext} +private[streaming] class QueueInputDStream[T: ClassManifest]( @transient ssc: StreamingContext, val queue: Queue[RDD[T]], |