对流数据进行交互式分析 - Amazon Kinesis Data Analytics
Flink 口译员Apache Flink 表环境变量
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

对流数据进行交互式分析

您可以使用由 Apache Zeppelin 提供支持的无服务器笔记本电脑与流媒体数据进行交互。你的笔记本可以有多个笔记，每个笔记都可以有一个或多个段落，你可以在其中编写代码。

以下示例 SQL 查询显示了如何从数据源中检索数据：

%flink.ssql(type=update)
select * from stock;

有关 Flink 流式处理 SQL 查询的更多示例，请参阅。示例和教程以下权限查询中的Apache Flink 文档.

您可以在 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 表环境资源：

变量 资源
senvStreamingTable环境
benvExecutionEnvironment
stenvStreamTable眨眼规划者的环境
btenvBatchTable眨眼规划者的环境
stenv_2StreamTableFlink 规划者的环境
btenv_2BatchTableFlink 规划者的环境

您可以使用以下变量访问 Python 表环境资源：

变量 资源
s_envStreamingTable环境
b_envExecutionEnvironment
st_envStreamTable眨眼规划者的环境
bt_envBatchTable眨眼规划者的环境
st_env_2StreamTableFlink 规划者的环境
bt_env_2BatchTableFlink 规划者的环境

有关使用表环境的更多信息，请参阅。创建TableEnvironment中的Apache Flink 文档.