Langkah 2: Buat Aplikasi Kinesis Data Analytics

Untuk membuat aplikasi

1. Buat aplikasi Kinesis Data Analytics dengan mengikuti langkah 1, 2, dan 3 dalam latihan Memulai (Langkah 3.1: Buat Aplikasilihat).

   Dalam konfigurasi sumber, lakukan hal berikut:

   • Tentukan sumber streaming yang Anda buat di Langkah 1 Buat Aliran Input dan Output.

   • Setelah konsol menyimpulkan skema, edit skema. Pastikan tipe kolom x dan y ditetapkan ke DOUBLE dan tipe kolom IS_HOT ditetapkan ke VARCHAR.

2. Gunakan kode aplikasi berikut (Anda dapat menempelkan kode ini ke editor SQL):

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
       "x" DOUBLE, 
       "y" DOUBLE, 
       "is_hot" VARCHAR(4),
       HOTSPOTS_RESULT VARCHAR(10000)
   ); 
   CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
       INSERT INTO "DESTINATION_SQL_STREAM" 
       SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" 
       FROM TABLE (
           HOTSPOTS(   
               CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 
               1000, 
               0.2, 
               17)
       );
   

3. Jalankan kode SQL dan tinjau hasilnya.