Freigeben über


IN

✅ Azure Stream Analytics ✅ Fabric Eventstream

INTO (Ausgabedatenstrom)

INTO gibt explizit einen Ausgabestream an und ist immer einem SELECT-Ausdruck zugeordnet. Wenn kein Wert angegeben wird, lautet der Standardausgabestream „output“.

Syntax

[ INTO <output_stream> ]  

Argumente

output_stream

Gibt den Namen eines Ausgabedatenstroms an.

Einschränkungen und Beschränkungen

Sie können SELECT nicht verwenden ... INTO in einer WITH-Klausel. Into-Klausel kann z. B. nur in der out-most subquery verwendet werden.

Beispiel

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 gibt explizit die Anzahl der Shards in einem Eingabeschritt an, wenn sie ein Partitionierungsschema (PARTITION BY) angeben. Wenn die Partitionsanzahl nicht angegeben ist, wird die Anzahl der Shards übertragen, wenn die PARTITION BY identisch oder zwei ist.

INTO ist ein Hinweis auf das System und kann ignoriert werden, wenn das System bestimmt, dass die explizite Spezifikation nicht von Vorteil ist.

INTO-Syntax

[ INTO <shard_count> ]  

INTO-Argumente

shard_count

Gibt die Anzahl der Scherben im Upstreamschritt an.

INTO-Einschränkungen und Einschränkungen

Die Shardanzahl muss größer als 1 sein. Beim Verknüpfen mehrerer Datenströme muss die Partitionsanzahl aller Eingaben identisch sein.

INTO-Beispiel

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId