步骤 2：创建 Kinesis Data Analytics 应用程序

创建应用程序

1. 按照入门练习中的步骤 1、2 和 3 创建 Kinesis 数据分析应用程序（参见步骤 3.1：创建应用程序）。

   在源配置中，执行以下操作：

   • 指定您在步骤 1：创建输入和输出流中创建的流式传输源。

   • 在控制台推断架构后编辑架构。确保 x 和 yDOUBLE 列类型设置为 ，并确保 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 代码并审查结果。