diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-01-21 11:39:30 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-01-21 11:39:30 +0530 |
| commit | 43bfd7bb21e6f8a9d083686a83bcd309a84f937e (patch) | |
| tree | 89e15f087b3067118c3118b08077294b9d20b715 /examples/src | |
| parent | 86057ec7c868262763d1e31b3f3c94bd43eeafb3 (diff) | |
| download | spark-43bfd7bb21e6f8a9d083686a83bcd309a84f937e.tar.gz spark-43bfd7bb21e6f8a9d083686a83bcd309a84f937e.tar.bz2 spark-43bfd7bb21e6f8a9d083686a83bcd309a84f937e.zip | |
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 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 99ed4cdc1c..2532f27d1a 100644 --- a/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala @@ -22,7 +22,7 @@ class TwitterInputDStream( storageLevel: StorageLevel ) extends NetworkInputDStream[Status](ssc_) { - override def createReceiver(): NetworkReceiver[Status] = { + override def getReceiver(): NetworkReceiver[Status] = { new TwitterReceiver(username, password, filters, storageLevel) } } |