diff options
| author | Prashant Sharma <prashant.iiith@gmail.com> | 2013-01-16 14:34:58 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.iiith@gmail.com> | 2013-01-19 22:04:07 +0530 |
| commit | bb6ab92e31b7aad464cf8262bc3567fdeb4c14c4 (patch) | |
| tree | 86222418c39416b4f841b89240380cf900709af0 /examples | |
| parent | 11bbe231408a3223d110c89519a70184d58408af (diff) | |
| download | spark-bb6ab92e31b7aad464cf8262bc3567fdeb4c14c4.tar.gz spark-bb6ab92e31b7aad464cf8262bc3567fdeb4c14c4.tar.bz2 spark-bb6ab92e31b7aad464cf8262bc3567fdeb4c14c4.zip | |
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
Diffstat (limited to 'examples')
| -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) } } |