INTO(Azure 스트림 분석)

아티클
08/02/2024

INTO(출력 스트림)

INTO는 출력 스트림을 명시적으로 지정하며 항상 SELECT 식과 연결됩니다. 지정하지 않으면 기본 출력 스트림은 “output”입니다.

Syntax

[ INTO <output_stream> ]

인수

output_stream

출력 스트림의 이름을 지정합니다.

제한 사항

SELECT ...를 사용할 수 없습니다. WITH 절의 INTO입니다. 예를 들어 INTO 절은 최외곽 하위 쿼리에서만 사용할 수 있습니다.

예제

WITH WAVehicle AS (  
    SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType,    VehicleWeight, Toll, Tag  
    FROM TollTagEntry TIMESTAMP BY EntryTime  
    WHERE State = "WA"
)  
  
SELECT * INTO WAVehicleArchive FROM WAVehicle;  
  
SELECT DateAdd(minute,-3,System.Timestamp()) AS WinStartTime, System.Timestamp() AS WinEndTime, COUNT(*) INTO WAVehicleCount FROM WAVehicle GROUP BY TumblingWindow(minute, 3)

INTO(분할된 데이터베이스 수)

INTO는 파티션 구성표(PARTITION BY)를 지정할 때 입력 단계에서 분할된 데이터베이스 수를 명시적으로 지정합니다. 파티션 수를 지정하지 않으면 PARTITION BY가 같거나 두 개일 경우 분할된 데이터베이스 수가 이월됩니다.

INTO는 시스템에 대한 힌트이며 시스템에서 명시적 사양이 도움이 되지 않는다고 판단하는 경우 무시될 수 있습니다.

INTO 구문

[ INTO <shard_count> ]

INTO 인수

shard_count

업스트림 단계의 분할된 데이터베이스 수를 지정합니다.

INTO 제한 사항 및 제한 사항

분할된 데이터베이스 수는 1보다 커야 합니다. 여러 스트림을 조인할 때 모든 입력의 파티션 수는 동일해야 합니다.

INTO 예제

WITH Step1 AS (
    SELECT * 
    FROM input 
    PARTITION BY DeviceId
    INTO 10
)

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

다음을 통해 공유