ステップ 2: Kinesis Data Analytics アプリケーションを作成する

アプリケーションを作成するには

1. 「使用開始」実習のステップ 1、2、および 3 (「ステップ 3.1: アプリケーションの作成」を参照) に従って Kinesis Data Analytics アプリケーションを作成します。

   ソース設定で、以下を実行します。

   • 作成したストリーミングソースを、ステップ 1: 入力ストリームと出力ストリームを作成する で指定します。

   • コンソールがスキーマを推測した後、スキーマを編集します。x 列および y 列のタイプが DOUBLE に設定され、IS_HOT 列のタイプが VARCHAR に設定されていることを確認します。

2. 次のアプリケーションコードを使用します (このコードを 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. SQL コードを実行して結果を確認します。