Analisis interaktif data streaming

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 berikut, dan Kueri 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 (API Tabel dan DataStream) untuk menulis program guna mengkueri 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

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	Membuat ExecutionEnvironment//StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironment dan menyediakan lingkungan Scala
%flink.pyflink	PyFlinkInterpreter	Menyediakan lingkungan python
%flink.ipyflink	Aku PyFlinkInterpreter	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.

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 dan Python.

Variabel lingkungan tabel Apache Flink

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_env	StreamExecutionEnvironment
st_env	StreamTableEnvironment for blink planner

Untuk informasi selengkapnya tentang penggunaan lingkungan tabel, lihat Konsep dan API Umum dalam dokumentasi Apache Flink.