INTO (Azure Stream Analytics)

  • Cikk

INTO (kimeneti stream)

Az INTO explicit módon meghatároz egy kimeneti streamet, és mindig EGY SELECT kifejezéshez van társítva. Ha nincs megadva, az alapértelmezett kimeneti stream a "kimenet".

Szintaxis

[ INTO <output_stream> ]

Argumentumok

output_stream

A kimeneti stream nevét adja meg.

Korlátozások és korlátozások

A SELECT ... nem használható. INTO egy WITH záradékban. Az INTO záradék például csak a legfelülibb lekérdezésekben használható.

Példa

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 (szegmensszám)

Az INTO explicit módon meghatározza a szegmensek számát egy bemeneti lépésben particionálási séma (PARTITION BY) megadásakor. Ha a partíciók száma nincs megadva, a szegmensek száma akkor lesz átadva, ha a PARTITION BY máskülönben azonos vagy két.

Az INTO a rendszerre utal, és figyelmen kívül hagyható, ha a rendszer megállapítja, hogy az explicit specifikáció nem előnyös.

INTO szintaxis

[ INTO <shard_count> ]

INTO argumentumok

shard_count

Megadja a szegmensek számát a felsőbb rétegbeli lépésben.

INTO korlátozások és korlátozások

A szegmensek számának 1-nél nagyobbnak kell lennie. Több stream összekapcsolásakor az összes bemenet partíciószámának meg kell egyeznie.

INTO példa

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId