2단계: Kinesis Data Analytics 애플리케이션 생성

애플리케이션 생성

1. 시작하기 연습 (단계 3.1: 애플리케이션 만들기 참조) 의 1, 2, 3단계에 따라 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 코드를 실행하고 결과를 검토합니다.