带有 zeppelin 笔记本的动态交互式仪表板

Question

我想要一个更具交互性的仪表板。就像从数据库中读取数据，将其提供给选择框，选择框的 onchange 发送值并运行查询。

我想在选定的值上使用 zeppelin bcz 来实现这一点，我必须显示分析。

实现这一目标的方法是什么，这是否可以通过 zeppelin 实现。

我尝试使用选择框，但我无法保存所选值并将其发送到下一个查询并执行它。 像

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

我不知道如何存储此参数并将所选参数从一个段落发送到另一个段落

或者像从 UI 处理所有这些事情，比如说 javascript html 并将选择的值作为参数发送到 zeppelin？就像是 这在使用 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>

并在我的 zeppelin 段落中使用这些 param1=value1&param2=value2？ 技术上可行与否我不明白。 请帮助我如何实现这一目标？ 在此先感谢:)

Answer 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 的段落会在值更改时自动执行。