如果段落从%jdbc解释器返回数据,该数据是否可用于使用其他解释器的后续段落?
例如
%jdbc(psql)
select * from `table`
然后
%python
# load / access data here
x = ...
与%spark解释器可以创建时态表的方式相同,以下段落可以运行%sql。
最佳答案
Apache Zeppelin具有Generic JDBC Interpreter,用于使用JDBC连接到不同的数据源。
现在,它已经通过以下测试:
Postgres
的MySQL
玛丽亚数据库
红移
阿帕奇蜂巢
阿帕奇凤凰
阿帕奇钻
根据org.apache.zeppelin.jdbc.JDBCInterpreter.executeSql
中的代码,它仅显示数据。
因此,可能存在从数据源获取数据并将其用于其他解释器的解决方案。
使用带有Scala解释器的Scala编写函数。它连接到数据源并根据查询结果生成DataFrame。
扩展JDBCInterpreter,或基于JDBCInterpreter创建一个新的解释器,该解释器将查询数据源并根据结果生成DataFrame。这可能需要扩展SQL语法才能添加此功能。