diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-13 16:18:39 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-13 16:18:39 -0800 |
commit | 0a2e33334125cb3ae5e54f8333ea5608779399fc (patch) | |
tree | 7dc0142b4c7c06cc4ac8d8682afbcb515003bf5a /examples | |
parent | 365506fb038a76ff3810957f5bc5823f5f16af40 (diff) | |
download | spark-0a2e33334125cb3ae5e54f8333ea5608779399fc.tar.gz spark-0a2e33334125cb3ae5e54f8333ea5608779399fc.tar.bz2 spark-0a2e33334125cb3ae5e54f8333ea5608779399fc.zip |
Removed stream id from the constructor of NetworkReceiver to make it easier for PluggableNetworkInputDStream.
Diffstat (limited to 'examples')
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala b/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala index c7e4855f3b..99ed4cdc1c 100644 --- a/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala @@ -23,16 +23,17 @@ class TwitterInputDStream( ) extends NetworkInputDStream[Status](ssc_) { override def createReceiver(): NetworkReceiver[Status] = { - new TwitterReceiver(id, username, password, filters, storageLevel) + new TwitterReceiver(username, password, filters, storageLevel) } } -class TwitterReceiver(streamId: Int, - username: String, - password: String, - filters: Seq[String], - storageLevel: StorageLevel - ) extends NetworkReceiver[Status](streamId) { +class TwitterReceiver( + username: String, + password: String, + filters: Seq[String], + storageLevel: StorageLevel + ) extends NetworkReceiver[Status] { + var twitterStream: TwitterStream = _ lazy val blockGenerator = new BlockGenerator(storageLevel) |