ScalaとSpark：createStream中にエラーが発生しました

Question

Error：ScalaとTwitter4jを使用してSparkでつぶやきのストリームを作成中にエラーが発生しました。以下 は、私のコードの抜粋です：

scala> val ssc = new StreamingContext(sc, Seconds(10)) 
scala> val cb = new ConfigurationBuilder 
scala>cb.setDebugEnabled(true).setOAuthConsumerKey("**********").setOAuthConsume 
scala> val auth = new OAuthAuthorization(cb.build) 
scala> val tweets = TwitterUtils.createStream(ssc,auth) 

error: overloaded method value createStream with alternatives: (jssc: org.apache.spaark.streaming.api.java.JavaStreamingContext, twitterAuth: twitter4j.auth.Authorization) org.apache.spark.streaming.api.java.JavaReceiverInputDStream[twitter4j.Status] (jssc:org.apache.spark.streaming.api.java.JavaStreamingContext, filters: Array[String])org.apache.spark.streaming.api.java.JavaReceiverInputDStream[twitter4j.Status] (ssc:org.apache.spark.streaming.StreamingContext,twitterAuth: Option[twitter4j.auth.Authorization],filters: Seq[String],storageLevel: org.apache.spark.storage.StorageLevel)org.apache.spark.streaming.dstream.ReceiverInputDStream[twitter4j.Status] cannot be applied to (org.apache.spark.streaming.StreamingContext, twitter4j.auth.OAuthAuthorization)

Answer 1

あなたがexpects a StreamingContext and an Option[Authorization]を使用している過負荷、ないAuthorization。

これは動作するはずです：

val tweets = TwitterUtils.createStream(ssc, Some(auth))