FAQ Layanan Terkelola Amazon untuk Apache Flink

Dengan Layanan Terkelola Amazon untuk Apache Flink, Anda dapat mengubah dan menganalisis data streaming secara waktu nyata dengan Apache Flink. Apache Flink adalah kerangka kerja sumber terbuka dan mesin untuk memproses aliran data. Layanan Terkelola Amazon untuk Apache Flink mengurangi kompleksitas saat membangun, mengelola, dan mengintegrasikan aplikasi Apache Flink dengan layanan AWS lainnya.

Layanan Terkelola Amazon untuk Apache Flink menangani semua yang diperlukan untuk terus menjalankan aplikasi streaming dan menskalakan secara otomatis agar sesuai dengan volume dan throughput data masuk Anda. Dengan Layanan Terkelola Amazon untuk Apache Flink, tidak ada server untuk dikelola, tidak ada biaya minimum atau biaya penyiapan, dan Anda hanya membayar sumber daya yang digunakan aplikasi streaming Anda.

Anda dapat menggunakan Layanan Terkelola Amazon untuk Apache Flink dalam banyak kasus penggunaan guna memproses data secara terus menerus agar dapat memperoleh wawasan dalam hitungan detik atau menit alih-alih menunggu berhari-hari atau bahkan berminggu-minggu. Layanan Terkelola Amazon untuk Apache Flink memungkinkan Anda dengan cepat membangun aplikasi pemrosesan streaming ujung ke ujung untuk analitik log, analitik clickstream, Internet untuk Segala (IoT), teknologi iklan, game, dan masih banyak lagi. Empat kasus penggunaan yang paling umum adalah streaming extract-transform-load (ETL), pembuatan metrik berkelanjutan, analitik waktu nyata responsif, dan kueri interaktif aliran data.

ETL Streaming

Dengan aplikasi ETL streaming, Anda dapat membersihkan, memperkaya, mengelola, dan mentransformasi data mentah sebelum memuat danau data atau gudang data dalam waktu nyata, sehingga mengurangi atau menghapus langkah-langkah ETL batch. Aplikasi ini dapat mem-buffer catatan kecil ke dalam file yang lebih besar sebelum mengirimkan dan melakukan penggabungan yang canggih di seluruh streaming dan tabel. Misalnya, Anda dapat membuat aplikasi yang terus membaca data sensor IoT yang disimpan di Amazon Managed Streaming untuk Apache Kafka (Amazon MSK), mengatur data berdasarkan jenis sensor, menghapus data duplikat, menormalkan data sesuai skema tertentu, dan kemudian mengirimkan data ke Amazon Simple Storage Service (Amazon S3).

Pembuatan metrik berkelanjutan

Dengan aplikasi pembuatan metrik berkelanjutan, Anda dapat memantau dan memahami tren data Anda dari waktu ke waktu. Aplikasi Anda dapat menggabungkan data streaming menjadi informasi penting dan mengintegrasikannya dengan basis data pelaporan dan layanan pemantauan untuk melayani aplikasi dan pengguna Anda secara waktu nyata. Dengan Layanan Terkelola Amazon untuk Apache Flink, Anda dapat menggunakan kode Apache Flink (di Java, Scala, Python, atau SQL) untuk terus menghasilkan analitik deret waktu sepanjang jendela waktu. Misalnya, Anda dapat membangun papan peringkat langsung untuk game seluler dengan menghitung pemain teratas setiap menit lalu mengirimkannya ke Amazon DynamoDB. Anda juga dapat melacak lalu lintas ke situs web Anda dengan menghitung jumlah pengunjung situs web unik setiap 5 menit lalu mengirimkan hasil yang diproses ke Amazon Redshift.

Analitik waktu nyata yang responsif

Aplikasi analitik waktu nyata yang responsif mengirimkan alarm atau notifikasi secara waktu nyata saat metrik tertentu mencapai ambang batas yang telah ditentukan atau, dalam kasus lanjutan, saat aplikasi Anda mendeteksi anomali menggunakan algoritma machine learning (ML). Dengan aplikasi ini, Anda dapat segera merespons perubahan dalam bisnis Anda secara waktu nyata, seperti memprediksi pengabaian pengguna di aplikasi seluler dan mengidentifikasi sistem yang terdegradasi. Misalnya, aplikasi dapat menghitung ketersediaan atau tingkat keberhasilan API yang dihadapi pelanggan dari waktu ke waktu lalu mengirimkan hasilnya ke Amazon CloudWatch. Anda dapat membangun aplikasi lain untuk mencari peristiwa yang memenuhi kriteria tertentu, lalu secara otomatis memberi tahu pelanggan yang tepat menggunakan Amazon Kinesis Data Streams dan Amazon Simple Notification Service (Amazon SNS).

Analisis interaktif aliran data

Analisis interaktif membantu Anda melakukan streaming eksplorasi data secara waktu nyata. Dengan kueri atau program ad hoc, Anda dapat memeriksa streaming dari Amazon MSK atau Amazon Kinesis Data Streams dan memvisualisasikan seperti apa data dalam streaming tersebut. Misalnya, Anda dapat melihat cara metrik waktu nyata yang menghitung rata-rata selama periode waktu berperilaku dan mengirim data agregat ke tujuan pilihan Anda. Analisis interaktif juga membantu pengembangan berulang aplikasi pemrosesan streaming. Kueri yang Anda buat terus diperbarui saat data baru tiba. Dengan Layanan Terkelola Amazon untuk Apache Flink Studio, Anda dapat melakukan deployment kueri ini agar berjalan terus menerus dengan penskalaan otomatis dan pencadangan status tahan lama diaktifkan. 

Ya, dengan Konektor Aliran Data Apache Flink, aplikasi Layanan Terkelola Amazon untuk Apache Flink dapat menggunakan Registri Skema AWS Glue, yaitu fitur nirserver AWS Glue. Anda dapat mengintegrasikan Apache Kafka, Amazon MSK, dan Amazon Kinesis Data Streams, sebagai sink atau sumber, dengan beban kerja Layanan Terkelola Amazon untuk Apache Flink. Kunjungi Panduan Pengembang AWS Glue Schema Registry untuk memulai dan mempelajari lebih lanjut.

Aplikasi adalah entitas Layanan Terkelola Amazon untuk Apache Flink yang bekerja dengan Anda. Aplikasi Layanan Terkelola Amazon untuk Apache Flink terus membaca dan memproses data streaming secara waktu nyata. Anda menulis kode aplikasi dalam bahasa yang didukung Apache Flink untuk memproses data streaming yang masuk dan menghasilkan output. Kemudian, Layanan Terkelola Amazon untuk Apache Flink menulis output ke tujuan yang dikonfigurasi.

Setiap aplikasi terdiri dari tiga komponen utama:

1. Input: Input adalah sumber streaming untuk aplikasi Anda. Dalam konfigurasi input, Anda memetakan sumber streaming ke aliran data. Data mengalir dari sumber data Anda ke aliran data Anda. Anda memproses data dari aliran data ini menggunakan kode aplikasi Anda, yang mengirimkan data yang diproses ke aliran atau tujuan data berikutnya. Anda menambahkan input di dalam kode aplikasi untuk aplikasi Apache Flink dan notebook Studio serta melalui API untuk aplikasi Layanan Terkelola Amazon untuk Apache Flink. 
2. Kode aplikasi: Kode aplikasi adalah serangkaian operator Apache Flink yang memproses input dan menghasilkan output. Dalam bentuknya yang paling sederhana, kode aplikasi dapat berupa operator Apache Flink tunggal yang membaca dari aliran data yang terkait dengan sumber streaming dan menulis ke aliran data lain yang terkait dengan output. Untuk notebook Studio, hal ini dapat berupa kueri pemilihan SQL Flink sederhana, dengan hasil yang ditampilkan dalam konteks di notebook. Anda dapat menulis kode Apache Flink dalam bahasa yang didukung untuk aplikasi Layanan Terkelola Amazon untuk Apache Flink atau notebook Studio.
3. Output: Anda kemudian dapat secara opsional mengonfigurasi output aplikasi untuk mempertahankan data ke tujuan eksternal. Anda menambahkan output ini di dalam kode aplikasi untuk aplikasi Layanan Terkelola Amazon untuk Apache Flink dan notebook Studio. 

AWS menyediakan berbagai alat yang dapat Anda gunakan untuk memantau aplikasi Layanan Terkelola Amazon untuk Apache Flink termasuk akses ke Dasbor Flink untuk aplikasi Apache Flink. Anda dapat mengonfigurasi beberapa alat ini guna melakukan pemantauan untuk Anda. Untuk informasi selengkapnya tentang cara memantau aplikasi Anda, jelajahi panduan developer berikut: 

• Memantau Layanan Terkelola Amazon untuk Apache Flink di Panduan Pengembang Layanan Terkelola Amazon untuk Apache Flink.
• Memantau Layanan Terkelola Amazon untuk Apache Flink di Panduan Pengembang Layanan Terkelola Amazon untuk Apache Flink Studio.

Layanan Terkelola Amazon untuk Apache Flink memerlukan izin untuk membaca catatan dari sumber data streaming yang Anda tentukan dalam aplikasi Anda. Layanan Terkelola Amazon untuk Apache Flink juga memerlukan izin untuk menulis output aplikasi Anda ke tujuan tertentu dalam konfigurasi output aplikasi Anda. Anda dapat memberikan izin ini dengan membuat peran AWS Identity and Access Management (IAM) yang dapat diambil oleh Layanan Terkelola Amazon untuk Apache Flink. Izin yang Anda berikan untuk peran ini menentukan apa yang dapat dilakukan Layanan Terkelola Amazon untuk Apache Flink saat layanan mengambil peran tersebut. Untuk informasi selengkapnya, lihat panduan developer berikut:

• Pemberian izin di Amazon Managed Service untuk Panduan Pengembang Apache Flink.
• Pemberian izin di Amazon Managed Service untuk Panduan Pengembang Apache Flink Studio.

Layanan Terkelola Amazon untuk Apache Flink menskalakan aplikasi Anda secara elastis untuk mengakomodasi throughput data streaming sumber dan kompleksitas kueri Anda untuk sebagian besar skenario. Layanan Terkelola Amazon untuk Apache Flink menyediakan kapasitas dalam bentuk KPU Amazon. Satu KPU memberi Anda 1 vCPU dan memori 4 GB. 

Untuk aplikasi Apache Flink dan notebook Studio, Layanan Terkelola Amazon untuk Apache Flink memberikan 50 GB untuk penyimpanan aplikasi yang sedang berjalan per KPU yang digunakan aplikasi Anda untuk titik pemeriksaan dan tersedia untuk digunakan melalui disk sementara. Titik pemeriksaan adalah cadangan terbaru dari aplikasi yang sedang berjalan yang digunakan untuk memulihkan segera dari gangguan aplikasi. Anda juga dapat mengontrol eksekusi paralel untuk tugas aplikasi Layanan Terkelola Amazon untuk Apache Flink (seperti membaca dari sumber atau menjalankan operator) menggunakan parameter Parallelism dan ParallelismPerKPU di API. Parallelism menentukan jumlah instans tugas yang bersamaan. Semua operator, sumber, dan sink berjalan dengan parallelism yang ditentukan secara default. Parallelism per KPU menentukan jumlah tugas paralel yang dapat dijadwalkan per KPU aplikasi Anda secara default. Untuk informasi selengkapnya, lihat Penskalaan di Panduan Developer Layanan Terkelola Amazon untuk Apache Flink. 

Untuk informasi tentang praktik terbaik untuk Apache Flink, lihat bagian Praktik Terbaik dari Panduan Pengembang Layanan Terkelola Amazon untuk Apache Flink. Bagian ini mencakup praktik terbaik untuk toleransi kesalahan, performa, logging, pengodean, dan banyak lagi. 

Untuk informasi tentang praktik terbaik Layanan Terkelola Amazon untuk Apache Flink Studio, lihat bagian Praktik Terbaik dari Panduan Developer Layanan Terkelola Amazon untuk Apache Flink Studio. Selain praktik terbaik, bagian ini mencakup contoh untuk aplikasi SQL, Python, dan Scala, persyaratan untuk melakukan deployment pada kode Anda sebagai aplikasi pemrosesan streaming yang terus berjalan, performa, logging, dan banyak lagi.

Ya. Anda dapat mengakses sumber daya di balik Amazon VPC. Anda dapat mempelajari cara mengonfigurasi aplikasi untuk akses VPC di bagian Menggunakan Amazon VPC dari Panduan Pengembang Layanan Terkelola Amazon untuk Apache Flink.

Aplikasi Layanan Terkelola Amazon untuk Apache Flink dan notebook Layanan Terkelola Amazon untuk Apache Flink Studio yang dikonfigurasi untuk mengakses sumber daya dalam VPC tertentu tidak memiliki akses ke internet sebagai konfigurasi default. Anda dapat mempelajari cara mengonfigurasi akses ke internet untuk aplikasi Anda di bagian Internet dan Akses Layanan dari Panduan Pengembang Amazon Managed Service for Apache Flink.

Dengan Layanan Terkelola Amazon untuk Apache Flink, Anda hanya membayar yang Anda gunakan. Tidak ada sumber daya untuk penyediaan atau biaya di muka yang berkaitan dengan Layanan Terkelola Amazon untuk Apache Flink. 

Anda dikenakan tarif per jam berdasarkan jumlah KPU Amazon yang digunakan untuk menjalankan aplikasi streaming Anda. KPU tunggal adalah seperangkat kapasitas pemrosesan streaming yang meliputi 1 komputasi vCPU dan memori 4 GB. Layanan Terkelola Amazon untuk Apache Flink secara otomatis menskalakan jumlah KPU yang diperlukan oleh aplikasi pemrosesan streaming Anda karena permintaan memori dan komputasi yang bervariasi sebagai respons terhadap kompleksitas pemrosesan dan throughput data streaming yang diproses. 

Untuk aplikasi Apache Flink dan Apache Beam, Anda dikenakan biaya KPU tunggal tambahan per aplikasi untuk orkestrasi aplikasi. Aplikasi Apache Flink dan Apache Beam juga dikenakan biaya untuk penyimpanan aplikasi yang sedang berjalan dan aplikasi pencadangan yang tahan lama. Penyimpanan aplikasi yang sedang berjalan digunakan untuk kemampuan pemrosesan stateful di Layanan Terkelola Amazon untuk Apache Flink dan dikenakan biaya per GB-bulan. Pencadangan aplikasi yang tahan lama adalah pilihan, dikenai biaya per GB-bulan, dan menyediakan suatu titik pemulihan waktu tertentu bagi aplikasi. 

Untuk Layanan Terkelola Amazon untuk Apache Flink Studio, dalam mode pengembangan atau interaktif, Anda dikenakan biaya tambahan KPU untuk orkestrasi aplikasi dan 1 KPU untuk pengembangan interaktif. Anda juga dikenakan biaya untuk penyimpanan aplikasi yang sedang berjalan. Anda tidak dikenakan biaya untuk pencadangan aplikasi yang tahan lama.

Untuk informasi harga selengkapnya, lihat halaman harga Amazon Managed Service untuk Apache Flink.

Untuk aplikasi Apache Flink dan Apache Beam, Anda dikenakan biaya minimal 2 KPU dan 50 GB untuk penyimpanan aplikasi yang sedang berjalan jika aplikasi Layanan Terkelola Amazon untuk Apache Flink Anda berjalan.

Untuk notebook Layanan Terkelola Amazon untuk Apache Flink Studio, Anda dikenakan biaya minimal 3 KPU dan 50 GB untuk penyimpanan aplikasi yang sedang berjalan jika aplikasi Anda berjalan.

Apache Flink adalah kerangka kerja dan mesin open source untuk pemrosesan data aliran dan batch. Apache Flink memudahkan dibangunnya aplikasi streaming karena menyediakan operator yang kuat dan memecahkan masalah streaming inti seperti pemrosesan duplikat. Apache Flink menyediakan distribusi data, komunikasi, dan toleransi kesalahan untuk perhitungan terdistribusi melalui aliran data.

Anda dapat memulai dengan mengunduh pustaka sumber terbuka termasuk AWS SDK, Apache Flink, dan konektor untuk layanan AWS. Dapatkan petunjuk tentang cara mengunduh pustaka dan membuat aplikasi pertama Anda di Panduan Pengembang Amazon Managed Service for Apache Flink.

Anda menulis kode Apache Flink Anda menggunakan aliran data dan operator streaming. Aliran data aplikasi adalah struktur data yang pemrosesannya Anda lakukan menggunakan kode Anda. Data terus mengalir dari sumber ke aliran data aplikasi. Satu atau beberapa operator streaming digunakan untuk menentukan pemrosesan Anda pada aliran data aplikasi, termasuk transformasi, partisi, agregat, gabungan, dan jendela. Aliran data dan operator dapat dihubungkan dalam rantai serial dan paralel. Contoh singkat menggunakan kode semu ditunjukkan di bawah ini.

DataStream <GameEvent> rawEvents = env.addSource(

New KinesisStreamSource(“input_events”));

DataStream <UserPerLevel> gameStream =

rawEvents.map(event - > new UserPerLevel(event.gameMetadata.gameId,

event.gameMetadata.levelId,event.userId));

gameStream.keyBy(event -> event.gameId)

.keyBy(1)

.window(TumblingProcessingTimeWindows.of(Time.minutes(1)))

.apply(...) - > {...};

gameStream.addSink(new KinesisStreamSink("myGameStateStream"));

Oper ator mengambil aliran data aplikasi sebagai input dan mengirim data yang diproses ke aliran data aplikasi sebagai output. Operator dapat dihubungkan untuk membangun aplikasi dengan beberapa langkah dan tidak memerlukan pengetahuan lanjutan tentang sistem terdistribusi untuk mengimplementasikan dan mengoperasikan.

Layanan Terkelola Amazon untuk Apache Flink mendukung semua operator dari Apache Flink yang dapat digunakan untuk memecahkan berbagai kasus penggunaan, termasuk peta, KeyBy, agregasi, jendela, gabungan, dan banyak lagi. Misalnya, operator peta memungkinkan Anda untuk melakukan pemrosesan acak, yang mengambil satu elemen dari aliran data yang masuk dan menghasilkan elemen lain. KeyBy secara logis mengatur data menggunakan kunci tertentu sehingga Anda dapat memproses titik data yang serupa bersama-sama. Agregasi melakukan pemrosesan di beberapa kunci, seperti jumlah, min, dan maks. Gabungan Jendela menggabungkan dua aliran data bersama-sama pada kunci dan jendela tertentu. 

Anda dapat membangun operator khusus jika hal ini tidak memenuhi kebutuhan Anda. Temukan lebih banyak contoh di bagian Operator dari Panduan Developer Layanan Terkelola Amazon untuk Apache Flink. Anda dapat menemukan daftar lengkap operator Apache Flink dalam dokumentasi Apache Flink. 

Anda dapat mengatur integrasi bawaan yang disediakan oleh Apache Flink dengan kode minimal atau membangun integrasi Anda sendiri untuk terhubung ke hampir semua sumber data. Pustaka sumber terbuka berdasarkan Apache Flink mendukung sumber dan tujuan streaming, atau sink, untuk memproses pengiriman data. Hal ini juga termasuk dukungan pengayaan data melalui konektor I/O asinkron. Beberapa konektor tersebut mencakup hal berikut:

• Sumber data streaming: Amazon Managed Streaming for Apache Kafka (Amazon MSK), Tujuan Amazon Kinesis Data Streams, atau sink: Amazon Kinesis Data Streams
• Amazon Kinesis Data Firehose, Amazon DynamoDB, Amazon Elasticsearch Service, dan Amazon S3 (melalui integrasi sink file)

Ya. Anda dapat menggunakan aplikasi Layanan Terkelola Amazon untuk Apache Flink guna mereplikasi data antara Amazon Kinesis Data Streams, Amazon MSK, dan sistem lainnya. Contoh yang disediakan dalam dokumentasi kami menunjukkan cara membaca dari satu topik Amazon MSK dan menulis ke topik lain.

Anda dapat menambahkan sumber atau tujuan ke aplikasi Anda dengan membangun serangkaian primitif yang memungkinkan Anda membaca dan menulis dari file, direktori, soket, atau apa pun yang dapat Anda akses melalui internet. Apache Flink menyediakan primitif ini untuk sumber data dan penyir am data. Primitif hadir dengan konfigurasi seperti kemampuan untuk membaca dan menulis data terus menerus atau satu kali, secara asinkron atau sinkron, dan banyak lagi. Misalnya, Anda dapat menyiapkan aplikasi untuk membaca terus menerus dari Amazon S3 dengan memperluas integrasi sumber berbasis file yang ada.

Aplikasi Apache Flink di Layanan Terkelola Amazon untuk Apache Flink menggunakan model pengiriman tepat satu kali jika aplikasi dibuat menggunakan operator idempoten, termasuk sumber dan sink. Hal ini berarti data yang diproses berdampak pada hasil hilir satu kali dan hanya satu kali.

Secara default, aplikasi Layanan Terkelola Amazon untuk Apache Flink menggunakan semantik Apache Flink tepat satu kali. Aplikasi Anda mendukung semantik pemrosesan tepat satu kali jika Anda mendesain aplikasi dengan menggunakan sumber, operator, dan sink yang menggunakan semantik tepat satu kali dari Apache Flink.

Layanan Terkelola Amazon untuk Apache Flink secara otomatis mencadangkan status aplikasi yang sedang berjalan menggunakan titik pemeriksaan dan snapshot. Titik pemeriksaan menyimpan status aplikasi saat ini dan mengaktifkan aplikasi Layanan Terkelola Amazon untuk Apache Flink untuk memulihkan posisi aplikasi guna menyediakan semantik yang sama dengan eksekusi bebas kegagalan. Titik pemeriksaan menggunakan penyimpanan aplikasi yang sedang berjalan. Checkpoint untuk aplikasi Apache Flink disediakan melalui fungsionalitas checkpointing Apache Flink. Snapshot menyimpan titik pemulihan titik waktu untuk aplikasi dan menggunakan pencadangan aplikasi yang tahan lama. Snapshot dianalogikan dengan titik penyimpanan Flink.

Untuk mempelajari selengkapnya tentang versi Apache Flink yang didukung, kunjungi halaman Catatan Rilis Layanan Terkelola Amazon untuk Apache Flink. Halaman ini juga mencakup versi Apache Beam, Java, Scala, Python, dan AWS SDK yang didukung Layanan Terkelola Amazon untuk Apache Flink. 

Ya, Amazon Managed Service for Apache Flink mendukung aplikasi streaming yang dibuat menggunakan Apache Beam. Anda dapat membangun aplikasi streaming Apache Beam di Java dan menjalankannya di berbagai mesin dan layanan termasuk menggunakan Apache Flink di Layanan Terkelola Amazon untuk Apache Flink. Anda dapat menemukan informasi mengenai versi Apache Flink dan Apache Beam yang didukung di Panduan Peng embang Amazon Managed Service for Apache Flink. 

Anda dapat memulai dari konsol Layanan Terkelola Amazon untuk Apache Flink Studio, Amazon Kinesis Data Streams, atau Amazon MSK dalam beberapa langkah guna meluncurkan notebook nirserver untuk langsung mengueri aliran data dan melakukan analitik data interaktif.

Analisis data interaktif: Anda dapat menulis kode di buku catatan di SQL, Python, atau Scala untuk berinteraksi dengan data streaming Anda, dengan waktu respons kueri dalam hitungan detik. Anda dapat menggunakan visualisasi bawaan untuk menjelajahi data, melihat wawasan waktu nyata pada data streaming Anda dari dalam notebook Anda, dan mengembangkan aplikasi pemrosesan streaming yang ditenagai oleh Apache Flink.

Setelah kode siap dijalankan sebagai aplikasi produksi, Anda dapat bertransisi dengan satu langkah ke aplikasi pemrosesan streaming yang memproses gigabita data per detik, tanpa server.

Aplikasi pemrosesan aliran: Setelah Anda siap untuk mempromosikan kode Anda ke produksi, Anda dapat membuat kode Anda dengan mengklik “Terapkan sebagai aplikasi pemrosesan aliran” di antarmuka notebook atau mengeluarkan satu perintah di CLI. Studio menangani semua manajemen infrastruktur yang diperlukan agar Anda dapat menjalankan aplikasi pemrosesan streaming dalam skala besar, dengan penskalaan otomatis dan status tahan lama diaktifkan, seperti dalam aplikasi Layanan Terkelola Amazon untuk Apache Flink.

Anda dapat melakukan operasi SQL seperti berikut:

• Pindai dan filter (SELECT, WHERE) 
• Agregasi (GROUP BY, GROUP BY WINDOW, HAVING) 
• Atur (UNION, UNIONALL, INTERSECT, IN, EXISTS) 
• Urutkan (ORDER BY, LIMIT) 
• Bergabung (INNER, OUTER, Timed Window – BETWEEN, AND, Bergabung dengan Tabel Temporal – tabel yang melacak perubahan dari waktu ke waktu)
• Top-N
• Deduplikasi
• Pengenalan pola

Beberapa kueri ini, seperti GROUP BY, OUTER JOIN, dan Top-N, adalah pembaruan hasil untuk data streaming, yang berarti bahwa hasilnya terus diperbarui saat data streaming diproses. Pernyataan DDL lainnya, seperti CREATE, ALTER, dan DROP, juga didukung. Untuk daftar lengkap kueri dan sampel, lihat dokumentasi Apache Flink Queries.

API Tabel milik Apache Flink mendukung Python dan Scala melalui integrasi bahasa menggunakan string Python dan ekspresi Scala. Operasi yang didukung sangat mirip dengan operasi SQL yang didukung, termasuk pilih, urutkan, kelompokkan, gabungan, filter, dan windowing. Daftar lengkap operasi dan sampel disertakan dalam panduan pengembang kami.

Untuk mempelajari selengkapnya tentang versi Apache Flink yang didukung, kunjungi halaman Catatan Rilis Layanan Terkelola Amazon untuk Apache Flink. Halaman ini juga mencakup versi Apache Zeppelin, Apache Beam, Java, Scala, Python, dan AWS SDK yang didukung Layanan Terkelola Amazon untuk Apache Flink.

• Sumber data: Amazon Managed Streaming for Apache Kafka (Amazon MSK), Amazon Kinesis Data Streams, Amazon S3 
• Tujuan, atau sink: Amazon MSK, Amazon Kinesis Data Streams, dan Amazon S3

Anda berhak mendapatkan Kredit Layanan SLA dari Layanan Terkelola Amazon untuk Apache Flink di bawah SLA Layanan Terkelola Amazon untuk Apache Flink jika lebih dari satu Zona Ketersediaan tempat Anda menjalankan tugas, dalam Wilayah AWS yang sama, memiliki Persentase Waktu Aktif Bulanan kurang dari 99,9% selama siklus penagihan bulanan. Untuk detail lengkap tentang semua syarat dan ketentuan SLA serta detail tentang cara mengajukan klaim, kunjungi halaman detail SLA Amazon Managed Service for Apache Flink.