本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
对流数据进行交互式分析
您可以使用由 Apache Zeppelin 提供支持的无服务器笔记本电脑与流媒体数据进行交互。你的笔记本可以有多个笔记,每个笔记都可以有一个或多个段落,你可以在其中编写代码。
以下示例 SQL 查询显示了如何从数据源中检索数据:
%flink.ssql(type=update) select * from stock;
有关 Flink 流式处理 SQL 查询的更多示例,请参阅。示例和教程以下权限查询
您可以在 Studio 笔记本中使用 Flink SQL 查询来查询流数据。您还可以使用 Python(表 API)和 Scala(表和数据流 API)编写程序以交互方式查询流数据。您可以查看查询或程序的结果,在几秒钟内更新它们,然后重新运行它们以查看更新的结果。
Flink 口译员
您可以通过使用翻译员. 您可以将以下解释器与 Kinesis Data Analytics 结合使用:
名称 | 类 | 说明 |
---|---|---|
%flink | FlinkInterpreter | Creates ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironment and provides a Scala environment |
%flink.pyflink | PyFlinkInterpreter | Provides a python environment |
%flink.ipyflink | IPyFlinkInterpreter | Provides an ipython environment |
%flink.ssql | FlinkStreamSqlInterpreter | Provides a stream sql environment |
%flink.bsql | FlinkBatchSqlInterpreter | Provides a batch sql environment |
有关 Flink 口译员的更多信息,请参阅。阿帕奇齐柏林的 Flink 翻译
Apache Flink 表环境变量
Apache Zeppelin 使用环境变量提供对表环境资源的访问权限。
您可以使用以下变量访问 Scala 表环境资源:
变量 | 资源 |
---|---|
senv | StreamingTable环境 |
benv | ExecutionEnvironment |
stenv | StreamTable眨眼规划者的环境 |
btenv | BatchTable眨眼规划者的环境 |
stenv_2 | StreamTableFlink 规划者的环境 |
btenv_2 | BatchTableFlink 规划者的环境 |
您可以使用以下变量访问 Python 表环境资源:
变量 | 资源 |
---|---|
s_env | StreamingTable环境 |
b_env | ExecutionEnvironment |
st_env | StreamTable眨眼规划者的环境 |
bt_env | BatchTable眨眼规划者的环境 |
st_env_2 | StreamTableFlink 规划者的环境 |
bt_env_2 | BatchTableFlink 规划者的环境 |
有关使用表环境的更多信息,请参阅。创建TableEnvironment