使用cassandra和spark对齐柏林飞艇进行可视化

Question

我刚接触齐柏林飞艇，但它看起来很有趣。我想用齐柏林飞艇中的spark对cassandra的数据读取做一些可视化处理。但我还不能这么做！

这是我的代码：

import org.apache.spark.sql.cassandra._
import org.apache.spark.sql
val createDDL = """CREATE TEMPORARY VIEW keyspaces9
 USING org.apache.spark.sql.cassandra
 OPTIONS (
 table "foehis",
 keyspace "tfm",
 pushdown "true")"""
spark.sql(createDDL) 
spark.sql("SELECT hoclic,hodtac,hohrac,hotpac FROM keyspaces").show

我得到了：

res41: org.apache.spark.sql.DataFrame = []
+------+--------+------+------+
|hoclic|  hodtac|hohrac|hotpac|
+------+--------+------+------+
|  1011|10180619|   510|  ENPR|
|  1011|20140427|   800|  ANDE|
|  1011|20140427|   800|  ANDE|
|  1011|20170522|  1100|  ANDE|
|  1011|20170522|  1100|  ANDE|
....

但我没有能力

如何将这些数据转换为zeppelin的表？

Answer 1

使用df.registerTempTable将DataFrame注册为表。在您的例子中，将‘keyspace’数据帧注册为表，然后您就可以在表上执行SQL查询并创建可视化效果。

示例代码：

​