스칼라의 스칼라 스트리밍 코드 오류

Question

스트리밍 트위터 데이터로 작업하는 스칼라에서 스팍 스트리밍을 사용하고 있습니다.

val ssc = new StreamingContext(new SparkConf(), Seconds(5)) 
val tweets = TwitterUtils.createStream(ssc, None) 

val user = tweets.map(x=> x.getText()) 
val lang = tweets.map(x=> x.getLang()) 

나는 다음과 같은 오류가 점점 오전 :

[error] /home/user/Lab1.1/Twitterstats.scala:103: value getLang is not a member of twitter4j.Status 
[error]     val lang = tweets.map(x=> x.getLang()) 
[error]           ^
[error] one error found 

위의 코드에 어떤 문제를 나는 다음과 같은 코드가? 누군가 도움을 청할 수 있습니까?

Answer 1

spark-streaming-twitterTwitter4j을 사용합니다. getLang()은 버전 3.0.6트위터 4J 이후에만 지원됩니다. 당신이 스파크 스트리밍 트위터의 버전 1.5.2 (이하)을 사용하는 경우이 버전 twitter4j의 3.0.3를 사용하기 때문에 당신은 getLang()를 호출 할 수 없습니다. 1.6.0 이후 버전 4.0.4은 getLang() 기능과 마찬가지로 지원됩니다.

스파크 스트리밍 - 트위터을 1.6.0 이상으로 업그레이드 할 수 있습니다. 또는 다른 타사 라이브러리를 사용하여 트윗의 언어를 검색 할 수 있습니다. (가능한 duplicate)