Apache Zeppelin是一款基于Web的笔记本电脑,支持数据驱动的交互式数据分析。您可以使用SQL,Python,Scala等制作精美的数据驱动,交互式和协作文档。它还支持Markdown语法。
如何使Spark SQL成为Zeppelin笔记本中的默认解释器?
在办公室,我们使用Zeppelin Notebooks和Spark作为默认解释器。大多数时候我使用Spark SQL。这是一个简单的例子:%SQL select * from db.table1如何使Spark SQL成为默认值...
为什么Zeppelin因“输入不匹配”而失败;'期待 “在%spark.sql段落?
我已经从csv构建了一个镶木地板文件。在Zeppelin中,我创建了一个sql语句,如:%spark.sql DROP TABLE IF EXISTS df; CREATE TABLE df(date_time STRING,site_name STRING,...
我需要将请求参数传递给指定的zeppelin段落,让它们可用于spark上下文。这是一场真正的噩梦。我可以在%angular解释器中写一些js来...
通过zeppelin从docker-hadoop-spark - workbench访问hdfs
我安装了https://github.com/big-data-europe/docker-hadoop-spark-workbench然后用docker-compose启动它。我导航到git自述文件中提到的各种网址,所有...
嗨,我正在尝试将BigInt转换为int以生成Rating类。我只想使用足够小的实例来使用以下代码:val tup = rs.select(“...
没有$ ZEPPELIN_HOME / scripts / docker / spark-cluster-managers / spark_standalone文件
我正在查看zeppelin文档以启动本地spark它说:cd $ ZEPPELIN_HOME / scripts / docker / spark-cluster-managers / spark_standalone但是在$ ZEPPELIN_HOME我没有脚本文件夹:...
我使用的是HDP-2.6.0.3,但我需要Zeppelin 0.8,所以我已将其作为独立服务安装。当我运行:%sql show tables我得不到任何回报,当我运行Spark2 SQL时,我得到'table not found'...
zeppelin独立用于学习目的与hdfs和spark我需要安装什么?
我不得不说我有点混淆,我不会对apache zeppelin文档提出异议,我有以下问题。我的目标是简单地让本地zeppelin与本地hdfs一起工作......
如何以不同于启动该过程的用户的用户身份运行Zeppelin解释器?我想以“root”身份运行Zeppelin,然后以“admin”用户身份启动spark应用程序
从Scala注册UDF到SqlContext以在PySpark中使用
是否可以注册用Scala编写的UDF(或函数)在PySpark中使用?例如:val mytable = sc.parallelize(1到2).toDF(“spam”)mytable.registerTempTable(“mytable”)def addOne(m:Integer)...
如何在apache zeppelin中使用hdfs shell命令?
我已经通过下载并使用所有解释器提取二进制文件来安装apache zeppelin然后启动它:./ bin / zeppelin.sh start然后我创建了一个新的笔记本,其中包含以下内容...
我正在使用Zeppelin 0.7.3版本。试图在postman中使用zeppelin REST API调用(http:// localhost:8080 / api / notebook / 2D8BSC25C / paragraph / 20180211-213728_2111839943)来更新段落,我...
我不能在Spark 1.6.0视图中使用input_file_name()函数。它适用于select语句或df.withColumn(“path”,input_file_name()),但不在视图中。例如:CREATE VIEW v_test ...
ZEPPELIN:无法找到或加载主类org.apache.zeppelin.server.ZeppelinServer
我有OS Red Hat Enterprise Linux Server 7.4版(Maipo)Ambari版本2.5.1.0 HDP 2.6试图启动Zeppelin Server返回错误:引发ExecutionFailed(err_msg,code,out,err)...
我对Zeppelin解释器的绑定模式有点困惑。我正在使用Zeppelin 0.7.2,据我了解,如果我配置一个具有“隔离”绑定模式的解释器,那么每个用户都会得到......
我一直在寻找一种动态更新selectForm默认值的方法。我的代码如下:%spark2.pyspark d_var = {} d_var ['one'] = [“0”] d_var ['two'] = [“1”] keys = [] values = [('...
PySpark MLLib Zeppelin Logistic回归度量标准错误:AssertionError:维度不匹配
我正在尝试使用MLLib在Pyspark中运行逻辑回归。该模型运行但我无法获得任何指标。我的数据采用csv格式,我将其转换如下:def load(prefix):...
(Zeppelin + Livy)SparkUI.appUIAddress(),一定是错的
我正在尝试使用Zeppelin配置livy以下文档:https://zeppelin.apache.org/docs/0.7.3/interpreter/livy.html但是当我运行时:%livy.spark sc.version我得到了以下内容错误:......
如何在Zeppelin中更改Python解释器的python安装位置?
在Zeppelin中为Python解释器指定的python安装位置在哪里?如何使用新的python安装目录更改Python解释器的python安装位置...