INTO (Azure Stream Analytics)

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

SQL

[ 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

SQL

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

SQL

[ 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

SQL

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId