Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Lakukan analisis interaktif data streaming
<a name="how-zeppelin-interactive"></a>

Anda menggunakan notebook nirserver yang didukung Apache Zeppelin untuk berinteraksi dengan data streaming Anda. Notebook Anda dapat memiliki beberapa catatan, dan setiap catatan dapat memiliki satu atau beberapa paragraf tempat Anda dapat menulis kode Anda.

Contoh kueri SQL berikut menunjukkan cara mengambil data dari sumber data:

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

Untuk lebih banyak contoh kueri Flink Streaming SQL, lihat [Contoh dan tutorial untuk notebook Studio di Managed Service untuk Apache Flink](how-zeppelin-examples.md) berikut, dan [Kueri](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/sql/queries/overview/) dalam dokumentasi Apache Flink.

Anda dapat menggunakan kueri SQL Flink di notebook Studio untuk mengkueri data streaming. Anda juga dapat menggunakan Python (API Tabel) dan Scala (Tabel dan Datastream APIs) untuk menulis program untuk menanyakan data streaming Anda secara interaktif. Anda dapat melihat hasil kueri atau program, memperbaruinya dalam hitungan detik, dan menjalankannya kembali untuk melihat hasil yang diperbarui.

## Interpreter Flink
<a name="how-zeppelin-interactive-interpreters"></a>

*Anda menentukan bahasa Managed Service untuk Apache Flink yang digunakan untuk menjalankan aplikasi Anda dengan menggunakan interpreter.* Anda dapat menggunakan interpreter berikut dengan Managed Service untuk Apache Flink:


| Nama | Kelas | Deskripsi | 
| --- |--- |--- |
| %flink | FlinkInterpreter | Menciptakan ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironmentdan menyediakan lingkungan Scala | 
| %flink.pyflink | PyFlinkInterpreter | Menyediakan lingkungan python | 
| %flink.ipyflink | IPyFlinkInterpreter | Menyediakan lingkungan ipython | 
| %flink.ssql | FlinkStreamSqlInterpreter | Menyediakan lingkungan stream sql | 
| %flink.bsql | FlinkBatchSqlInterpreter | Menyediakan lingkungan batch sql | 

Untuk informasi selengkapnya tentang interpreter Flink, lihat [ Interpreter Flink untuk Apache Zeppelin](https://zeppelin.apache.org/docs/0.9.0/interpreter/flink.html).

Jika Anda menggunakan `%flink.pyflink` atau `%flink.ipyflink` sebagai penerjemah Anda, Anda harus menggunakan `ZeppelinContext` untuk memvisualisasikan hasil dalam buku catatan.

Untuk contoh yang lebih PyFlink spesifik, lihat [Kueri aliran data Anda secara interaktif menggunakan Layanan Terkelola untuk Apache Flink Studio](https://aws.amazon.com/blogs/big-data/query-your-data-streams-interactively-using-kinesis-data-analytics-studio-and-python/) dan Python.

## Variabel lingkungan tabel Apache Flink
<a name="how-zeppelin-interactive-env-vars"></a>

Apache Zeppelin menyediakan akses ke sumber daya lingkungan tabel menggunakan variabel lingkungan. 

Anda mengakses sumber daya lingkungan tabel Scala dengan variabel berikut:


| Variabel | Sumber daya | 
| --- |--- |
| senv | StreamExecutionEnvironment | 
| stenv | StreamTableEnvironment for blink planner | 

Anda mengakses sumber daya lingkungan tabel Python dengan variabel berikut:


| Variabel | Sumber daya | 
| --- |--- |
| s\$1env | StreamExecutionEnvironment | 
| st\$1env | StreamTableEnvironment for blink planner | 

Untuk informasi selengkapnya tentang penggunaan lingkungan tabel, lihat [Konsep dan API Umum](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/common/) dalam dokumentasi Apache Flink.