DANS

✅ Azure Stream Analytics ✅ Fabric Eventstream

INTO (flux de sortie)

INTO spécifie explicitement un flux de sortie, et est toujours associé à une expression SELECT. Si non spécifié, le flux de sortie par défaut est « output ».

Syntaxe

[ INTO <output_stream> ]  

Les arguments

output_stream

Spécifie le nom d’un flux de sortie.

Limitations et restrictions

Vous ne pouvez pas utiliser SELECT ... INTO dans une clause WITH. Par exemple, la clause INTO ne peut être utilisée que dans la sous-requête out-most.

Exemple :

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 (nombre de partitions)

INTO spécifie explicitement le nombre de partitions dans une étape d’entrée lors de la spécification d’un schéma de partitionnement (PARTITION BY). Si le nombre de partitions n’est pas spécifié, le nombre de partitions est transféré si partition BY est identique ou deux dans le cas contraire.

INTO est un indicateur du système et peut être ignoré si le système détermine la spécification explicite n’est pas bénéfique.

Syntaxe INTO

[ INTO <shard_count> ]  

INTO Arguments

shard_count

Spécifie le nombre de partitions dans l’étape en amont.

Limitations et restrictions INTO

Le nombre de partitions doit être supérieur à 1. Lors de la jonction de plusieurs flux, le nombre de partitions de toutes les entrées doit être identique.

EXEMPLE INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId