Apache Zeppelin是一款基于Web的笔记本电脑,支持数据驱动的交互式数据分析。您可以使用SQL,Python,Scala等制作精美的数据驱动,交互式和协作文档。它还支持Markdown语法。
如何以不同于启动该过程的用户的用户身份运行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安装位置...
我使用Zeppelin 0.7.2并为测试目的创建了一个自己的“解释器”,用于使用jdbc直接查询sql数据库。如果我使用sql查询从zeppelin中的表中选择col,请检查分散...