Apache Zeppelin 0.6.1 : Run Spark 2.0 Twitter Stream App

Question

Spark 2.0 및 Zeppelin 0.6.1이 설치된 클러스터가 있습니다. TwitterUtils.scala 클래스가 Spark 프로젝트에서 Apache Bahir로 이동했기 때문에 Zeppelin 노트북에서 TwitterUtils를 더 이상 사용할 수 없습니다. 여기

내 노트북의 조각 :

종속성로드 :

%dep 
z.reset 
z.load("org.apache.bahir:spark-streaming-twitter_2.11:2.0.0") 

DepInterpreter(%dep) deprecated. Remove dependencies and repositories through GUI interpreter menu instead. 
DepInterpreter(%dep) deprecated. Load dependency through GUI interpreter menu instead. 
res1: org.apache.zeppelin.dep.Dependency = org.apache.zeppelin.dep.Dependency@4793109a 

그리고 스파크 부분 :

import org.apache.spark.streaming.twitter 
import org.apache.spark.streaming._ 
import org.apache.spark.storage.StorageLevel 
import scala.io.Source 
import scala.collection.mutable.HashMap 
import java.io.File 
import org.apache.log4j.Logger 
import org.apache.log4j.Level 
import sys.process.stringSeqToProcess 
import org.apache.spark.SparkConf 

// ********************************* Configures the Oauth Credentials for accessing Twitter **************************** 
def configureTwitterCredentials(apiKey: String, apiSecret: String, accessToken: String, accessTokenSecret: String) {...} 

// ***************************************** Configure Twitter credentials ******************************************** 
val apiKey = ... 
val apiSecret = ... 
val accessToken = ... 
val accessTokenSecret = ... 
configureTwitterCredentials(apiKey, apiSecret, accessToken, accessTokenSecret) 

// ************************************************* The logic itself ************************************************* 
val ssc = new StreamingContext(sc, Seconds(2)) 
val tweets = TwitterUtils.createStream(ssc, None) 
val twt = tweets.window(Seconds(60)) 

내가 가져온 후 노트북의 불꽃 부분을 실행하려고하면 종속성, 나는 다음과 같은 예외가 발생합니다 :

<console>:44: error: object twitter is not a member of package org.apache.spark.streaming 
    import org.apache.spark.streaming.twitter 

여기서 내가 뭘 잘못하고 있니? Bahir 문서에서도 import org.apache.spark.streaming.twitter._ 명령을 사용합니다. http://bahir.apache.org/docs/spark/2.0.0/spark-streaming-twitter/

Answer 1

글쎄, 은 정확하지 않으며 어쨌든 지원되는 방법을 사용하지 않는 이유는 무엇입니까?