INTO (Azure Stream Analytics)

Článek
08/02/2024

INTO (Výstupní stream)

INTO explicitně určuje výstupní datový proud a je vždy přidružený k výrazu SELECT. Pokud není zadaný, výchozí výstupní datový proud je "output".

Syntaxe

[ INTO <output_stream> ]

Argumenty

output_stream

Určuje název výstupního datového proudu.

Omezení a omezení

Nelze použít příkaz SELECT... INTO v klauzuli WITH. Například klauzuli INTO lze použít pouze v poddotazu out-most.

Příklad

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 (počet horizontálních oddílů)

INTO explicitně určuje počet horizontálních oddílů ve vstupním kroku při zadávání schématu dělení (PARTITION BY). Pokud není zadaný počet oddílů, počet horizontálních oddílů se přenese, pokud je HODNOTA PARTITION BY stejná nebo dvě jinak.

INTO je nápověda pro systém a může být ignorována, pokud systém určí explicitní specifikaci není výhodná.

Syntaxe INTO

[ INTO <shard_count> ]

Argumenty INTO

shard_count

Určuje počet horizontálních oddílů v upstreamovém kroku.

Omezení a omezení INTO

Počet horizontálních oddílů musí být větší než 1. Při spojování několika datových proudů musí být počet oddílů všech vstupů stejný.

Příklad INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Sdílet prostřednictvím