INTO (Azure Stream Analytics)

  • Makale

INTO (Çıkış Akışı)

INTO bir çıkış akışını açıkça belirtir ve her zaman bir SELECT ifadesiyle ilişkilendirilir. Belirtilmezse, varsayılan çıkış akışı "output" olur.

Söz dizimi

[ INTO <output_stream> ]

Bağımsız değişkenler

output_stream

Çıkış akışının adını belirtir.

Sınırlamalar ve Kısıtlamalar

SELECT ... kullanamazsınız WITH yan tümcesinde INTO. Örneğin, INTO yan tümcesi yalnızca en dıştaki alt sorguda kullanılabilir.

Örnek

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 (Parça Sayısı)

INTO, bölümleme şeması (BÖLÜMLE) belirtirken bir giriş adımındaki parça sayısını açıkça belirtir. Bölüm sayısı belirtilmezse, PARTITION BY aynı veya iki farklıysa parça sayısı taşınır.

INTO, sisteme bir ipucudur ve sistem açık belirtimin yararlı olmadığını belirlerse yoksayılabilir.

INTO Söz Dizimi

[ INTO <shard_count> ]

INTO Bağımsız Değişkenleri

shard_count

Yukarı akış adımındaki parça sayısını belirtir.

INTO Sınırlamaları ve Kısıtlamaları

Parça sayısı 1'den büyük olmalıdır. Birkaç akış birleştirirken, tüm girişlerin bölüm sayısı aynı olmalıdır.

INTO Örneği

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId