1

よりインタラクティブなダッシュボードが必要です。データベースからデータを読み取り、それを選択ボックスに渡し、選択ボックスの変更時に値を送信してクエリを実行するように。

選択した値で zeppelin bcz を使用してこれを実現したいので、分析を表示する必要があります。

これを達成する方法は何であり、ツェッペリンを介して達成することは可能ですか.

選択ボックスを試してみましたが、選択した値を保存して次のクエリに送信して実行することができませんでした。何かのようなもの

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

このパラメーターを保存し、選択したパラメーターをある段落から別の段落に送信する方法がわかりませんでした

または、UIからこれらすべてを処理するようなもの、javascript htmlと言って、その選択した値をパラメーターとしてツェッペリンに送信しますか? URLを使用しているときにこのようなもの

<iframe src="http://myipaddress:8080/#/notebook/2BWCNP7V8/paragraph/20160831-115204_1774035770?asIframe&param1=value1&param2=value2" width="500" height="300"  scrolling="no" frameBorder="0" id="iframe1" style="text-align:center;" >Browser not compatible.</iframe>

私のツェッペリン段落でこれらの param1=value1¶m2=value2 を使用していますか? 技術的に実行可能かどうかはわかりません。これを達成する方法を教えてください。前もって感謝します ：）

4

1 に答える 1

1

次のコードですべての婚姻を取得できます

val maritals = bank.select("marital").distinct.collect.map(_.getString(0))

そして seq ZeppelinContext に変換したい

val seq = mairitals.zipWithIndex.map{case (x,y) => (y.toString, x)}.toSeq

次に、このように選択できます

val index = z.select("marital", "1", seq)
val marital = seq(index.toString.toInt)._2

そして、maritalさらなる処理に使用することができます。お気に入り。

val sql = s"""select distinct job from bank where marital=="$marital""""

sqlContext.sql(sql).show

または、spark-highchartsを使用するときのように。この場合、特定の婚姻状況の年齢に対する平均バランスをプロットしたいと思います。

highcharts(bank.filter(col("marital") === marital)
  .series("x" -> "age", "y" -> avg(col("balance")))
  .orderBy(col("age"))).plot()

注:select値が変更されると、 が含まれる段落のみが自動的に実行されます。

于 2016-09-02T07:15:41.947 に答える