diff options
author | James Phillpotts <jphillpotts@scottlogic.co.uk> | 2013-06-24 09:15:17 +0100 |
---|---|---|
committer | James Phillpotts <jphillpotts@scottlogic.co.uk> | 2013-06-24 09:15:17 +0100 |
commit | 8955787a596216a35ad4ec52b57331aa40444bef (patch) | |
tree | e56575e7bbc77c6c045edca60750e56a23bd8e70 /streaming | |
parent | 93a1643405d7c1a1fffe8210130341f34d64ea72 (diff) | |
download | spark-8955787a596216a35ad4ec52b57331aa40444bef.tar.gz spark-8955787a596216a35ad4ec52b57331aa40444bef.tar.bz2 spark-8955787a596216a35ad4ec52b57331aa40444bef.zip |
Twitter API v1 is retired - username/password auth no longer possible
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/StreamingContext.scala | 16 |
1 files changed, 1 insertions, 15 deletions
diff --git a/streaming/src/main/scala/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/spark/streaming/StreamingContext.scala index f97e47ada0..05be6bd58a 100644 --- a/streaming/src/main/scala/spark/streaming/StreamingContext.scala +++ b/streaming/src/main/scala/spark/streaming/StreamingContext.scala @@ -27,7 +27,7 @@ import org.apache.hadoop.mapreduce.{InputFormat => NewInputFormat} import org.apache.hadoop.mapreduce.lib.input.TextInputFormat import org.apache.hadoop.fs.Path import twitter4j.Status -import twitter4j.auth.{Authorization, BasicAuthorization} +import twitter4j.auth.Authorization /** * A StreamingContext is the main entry point for Spark Streaming functionality. Besides the basic @@ -363,20 +363,6 @@ class StreamingContext private ( /** * Create a input stream that returns tweets received from Twitter. - * @param username Twitter username - * @param password Twitter password - * @param filters Set of filter strings to get only those tweets that match them - * @param storageLevel Storage level to use for storing the received objects - */ - def twitterStream( - username: String, - password: String, - filters: Seq[String] = Nil, - storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2 - ): DStream[Status] = twitterStream(new BasicAuthorization(username, password), filters, storageLevel) - - /** - * Create a input stream that returns tweets received from Twitter. * @param twitterAuth Twitter4J authentication * @param filters Set of filter strings to get only those tweets that match them * @param storageLevel Storage level to use for storing the received objects |