INTO (Azure Stream Analytics)

Artikel
08/02/2024

INTO (uitvoerstroom)

INTO geeft expliciet een uitvoerstroom op en is altijd gekoppeld aan een SELECT-expressie. Als dit niet is opgegeven, is de standaarduitvoerstroom 'uitvoer'.

Syntaxis

[ INTO <output_stream> ]

Argumenten

output_stream

Hiermee geeft u de naam van een uitvoerstroom.

Beperkingen en beperkingen

U kunt SELECT niet gebruiken... INTO in een WITH-component. De COMPONENT INTO kan bijvoorbeeld alleen worden gebruikt in de meest gebruikte subquery.

Voorbeeld

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 (aantal shards)

IN geeft expliciet het aantal shards in een invoerstap op bij het opgeven van een partitioneringsschema (PARTITION BY). Als het aantal partities niet is opgegeven, wordt het aantal shards overgedragen als partition by hetzelfde is of twee andere.

INTO is een hint naar het systeem en kan worden genegeerd als het systeem vaststelt dat de expliciete specificatie niet nuttig is.

INTO-syntaxis

[ INTO <shard_count> ]

INTO-argumenten

shard_count

Hiermee geeft u het aantal shards in de upstream-stap op.

Into-beperkingen en -beperkingen

Het aantal shards moet groter zijn dan 1. Wanneer u meerdere streams samenvoegt, moet het aantal partities van alle invoer hetzelfde zijn.

INTO-voorbeeld

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Delen via