Langkah 3.4: (Opsional) Perbarui Kode Aplikasi

Untuk memperbarui kode aplikasi

1. Buat aliran dalam aplikasi lainnya seperti berikut:

   • Buat aliran dalam aplikasi lainnya yang disebut DESTINATION_SQL_STREAM_2.

   • Buat pompa, lalu gunakan untuk memasukkan baris dalam aliran yang baru dibuat dengan memilih baris dari DESTINATION_SQL_STREAM.

   Di SQL editor, tambahkan kode berikut ke kode aplikasi yang ada:

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS 
      INSERT INTO "DESTINATION_SQL_STREAM_2"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "DESTINATION_SQL_STREAM";

   Simpan dan jalankan kode. Aliran dalam aplikasi tambahan muncul di tab Real-time analytics (Analitik waktu nyata).

2. Buat dua aliran dalam aplikasi. Filter baris di SOURCE_SQL_STREAM_001 berdasarkan ticker saham, lalu masukkan ke dalam aliran terpisah ini.

   Tambahkan SQL pernyataan berikut ke kode aplikasi Anda:

   CREATE OR REPLACE STREAM "AMZN_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "AMZN_PUMP" AS 
      INSERT INTO "AMZN_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%AMZN%';
   
   CREATE OR REPLACE STREAM "TGT_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "TGT_PUMP" AS 
      INSERT INTO "TGT_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%TGT%';

   Simpan dan jalankan kode. Perhatikan aliran dalam aplikasi tambahan di tab Real-time analytics (Analitik waktu nyata).