Removed stream id from the constructor of NetworkReceiver to make it easier for PluggableNetworkInputDStream.

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)