Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Menggunakan konektor streaming terstruktur Spark Amazon Kinesis Data Streams
Amazon EMR rilis 7.1.0 dan yang lebih tinggi menyertakan konektor streaming terstruktur Amazon Kinesis Data Streams dalam gambar rilis. Dengan konektor ini, Anda dapat menggunakan Spark di Amazon EMR untuk memproses data yang disimpan di Amazon Kinesis Data Streams. Konektor mendukung kedua jenis konsumen GetRecords (throughput bersama) dan SubscribeToShard (fan-out yang ditingkatkan). Integrasi ini didasarkan pada
spark-sql-kinesis-connector
Contoh berikut menunjukkan cara menggunakan konektor untuk meluncurkan aplikasi Spark dengan Amazon EMR
spark-submitmy_kinesis_streaming_script.py