翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# ストリーミングデータのインタラクティブ分析を実行する
<a name="how-zeppelin-interactive"></a>

Apache Zeppelin を搭載したサーバーレス・ノートブックを使用して、ストリーミングデータとやり取りします。ノートブックには複数のノートを書くことができ、各ノートにはコードを書く段落を 1 つ以上書くことができます。

次の SQL クエリの例は、データソースからデータを取得する方法を示しています。

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

Flink ストリーミング SQL クエリのその他の例については、次の [Managed Service for Apache Flink の Studio ノートブックの例とチュートリアル](how-zeppelin-examples.md) および 「Apache Flink ドキュメント」の「[クエリ](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/sql/queries/overview/)」を参照してください。

Studio ノートブックの Flink SQL クエリを使用してストリーミングデータをクエリできます。また、Python（Table API）や Scala（Table API と Datastream API）を使って、ストリーミングデータをインタラクティブにクエリするプログラムを書くこともできます。クエリやプログラムの結果を表示し、数秒で更新して再実行し、更新された結果を表示することができます。

## Flink インタプリタ
<a name="how-zeppelin-interactive-interpreters"></a>

*インタープリタ*を使用して、Managed Service for Apache Flink がアプリケーションの実行に使用する言語を指定します。Apache Flink 用 Managed Serviceでは、以下のインタプリタを使用できます。


| 名前 | Class | 説明 | 
| --- |--- |--- |
| %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 インタープリタの詳細情報については、「[Apache Zeppelin 用 Flink インタープリタ](https://zeppelin.apache.org/docs/0.9.0/interpreter/flink.html)」を参照してください。

インタプリタとして `%flink.pyflink` または `%flink.ipyflink` を使用している場合は、`ZeppelinContext`を使用してノートブック内で結果を視覚化する必要があります。

PyFlink 固有のその他の例については、「[Apache Flink Studio と Python 用 Managed Service を使用してデータストリームをインタラクティブにクエリする](https://aws.amazon.com/blogs/big-data/query-your-data-streams-interactively-using-kinesis-data-analytics-studio-and-python/)」を参照してください。

## Apache Flink テーブルの環境変数
<a name="how-zeppelin-interactive-env-vars"></a>

Apache Zeppelin では、環境変数を使用してテーブル環境リソースにアクセスできます。

以下の変数を使用して Scala テーブル環境リソースにアクセスします。


| 変数 | [リソース]  | 
| --- |--- |
| senv | StreamExecutionEnvironment | 
| stenv | ブリンクプランナー用 StreamTableEnvironment | 

以下の変数を使用して Python テーブル環境リソースにアクセスします。


| 変数 | [リソース]  | 
| --- |--- |
| s\$1env | StreamExecutionEnvironment | 
| st\$1env | ブリンクプランナー用 StreamTableEnvironment | 

テーブル環境の使用の詳細については、「Apache Flink ドキュメント」の「[Concepts and Common API](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/common/)」を参照してください。