INTO (Azure Stream Analytics)

Artikel
08/02/2024

INTO (Aliran Output)

INTO secara eksplisit menentukan aliran output, dan selalu dikaitkan dengan ekspresi SELECT. Jika tidak ditentukan, aliran output default adalah "output".

Sintaks

[ INTO <output_stream> ]

Argumen

output_stream

Menentukan nama aliran output.

Batasan dan Pembatasan

Anda tidak dapat menggunakan SELECT ... INTO dalam klausa WITH. Misalnya, klausa INTO hanya dapat digunakan dalam subkueri paling luar.

Contoh

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 (Jumlah Shard)

INTO secara eksplisit menentukan jumlah pecahan dalam langkah input saat menentukan skema partisi (PARTITION BY). Jika jumlah partisi tidak ditentukan, jumlah pecahan dibawa jika PARTITION BY sama atau dua sebaliknya.

INTO adalah petunjuk untuk sistem, dan dapat diabaikan jika sistem menentukan spesifikasi eksplisit tidak bermanfaat.

Sintaks INTO

[ INTO <shard_count> ]

Argumen INTO

shard_count

Menentukan jumlah pecahan dalam langkah upstram.

Batasan dan Pembatasan INTO

Jumlah pecahan harus lebih besar dari 1. Saat menggabungkan beberapa aliran, jumlah partisi semua input harus sama.

Contoh INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Bagikan melalui