zepelin-0.7.2-bin-allのインストールと使用

1ダウンロード
公式アドレス:

http://zeppelin.apache.org/

2 conf/zepelin-env.shを修正し、export SPARK_ホーム?ム


3 conf/zepelin-site.xmlのzepelin.server.portを修正します.

cp zeppelin-site.xml.template zeppelin-site.xml
vim zeppelin-site.xml

4 Starting Apache Zeppelin

bin/zeppelin-daemon.sh start

hjr:8089

5テスト

5.1年齢の分布

val bankText = sc.textFile("/Zeppelin/bank-full.csv")

case class Bank(age:Integer, job:String, marital : String, education : String, balance : Integer)

val bank = bankText.map(s=>s.split(";")).filter(s=>s(0)!="\"age\"").map(
    s=>Bank(s(0).toInt, 
            s(1).replaceAll("\"", ""),
            s(2).replaceAll("\"", ""),
            s(3).replaceAll("\"", ""),
            s(5).replaceAll("\"", "").toInt
        )
)

// Below line works only in spark 1.3.0.
// For spark 1.1.x and spark 1.2.x,
// use bank.registerTempTable("bank") instead.
bank.toDF().registerTempTable("bank")

%sql select age, count(1) from bank where age < 30 group by age order by age

5.2 maxAgeパラメータを動的に入力する

%sql select age, count(1) from bank where age < ${maxAge=30} group by age order by age

5.3婚姻状況のオプションにより、年齢分布状況を確認する.

%sql select age, count(1) from bank where marital="${marital=single,single|divorced|married}" group by age order by age

6 Zeppelin Tutorial/Baic Feature(Spark)を実行します.



参考:
http://blog.csdn.net/stark_summer/articale/detail/48318059