INTO (Azure Stream Analytics)

Artikel
08/02/2024

INTO (utdataström)

INTO anger uttryckligen en utdataström och är alltid associerad med ett SELECT-uttryck. Om inget anges är standardutdataströmmen "output".

Syntax

[ INTO <output_stream> ]

Argument

output_stream

Anger namnet på en utdataström.

Begränsningar och begränsningar

Du kan inte använda SELECT ... INTO i en WITH-sats. TILL exempel kan INTO-satsen endast användas i den mest utgående underfrågan.

Exempel

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

INTO anger uttryckligen antalet shards i ett indatasteg när du anger ett partitioneringsschema (PARTITION BY). Om partitionsantalet inte anges överförs antalet shards om PARTITION BY är samma eller två på annat sätt.

INTO är en ledtråd till systemet och kan ignoreras om systemet fastställer att den uttryckliga specifikationen inte är fördelaktig.

INTO-syntax

[ INTO <shard_count> ]

INTO-argument

shard_count

Anger antalet shards i det överordnade steget.

INTO-begränsningar och begränsningar

Antalet shard måste vara större än 1. När du ansluter flera strömmar måste partitionsantalet för alla indata vara detsamma.

INTO-exempel

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Dela via