从Zeppelin-0.7开始,Zeppelin开始使用Helium Framework支持Helium插件/软件包.但是,我无法在Helium页面上查看任何插件(localhost:8080 /#/ helium).根据这个JIRA,我在/ local-repo/helium-registry-cache下放置了样本Helium.json(在s3上可用).但是,之后我在重启Apache Zeppelin服务时获得了NPE.
我尝试过Zeppelin 0.7以及Zeppelin 0.8.0 snaptshot版本.特别是,我想在Zeppelin笔记中使用地图Helium包 - Helium-Map.
有人可以向我指出在Zeppelin中使用Helium包的详细步骤的任何指南或文档吗?任何帮助将不胜感激!
我正在使用spark-cassandra-connector_2.11(版本2.0.5)将数据从Cassandra加载到Spark集群中。我正在使用 read api 加载数据,如下所示:
SparkUtil.initSpark()
.read
.format("org.apache.spark.sql.cassandra")
.options(Map("table"-><table_name>, "keyspace"-><keyspace>))
.load()
Run Code Online (Sandbox Code Playgroud)
然而,它工作正常,在一个用例中我只想读取 Cassandra 的特定列。如何使用 read api 来做同样的事情?