INTO (Azure Stream Analytics)

Article
08/02/2024

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> ]

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 est utilisable uniquement 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 reporté si PARTITION BY est identique ou deux dans le cas contraire.

INTO est un indicateur pour le système, et peut être ignoré si le système détermine que 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 amont.

Limitations et restrictions INTO

Le nombre de partitions doit être supérieur à 1. Lorsque vous joignez 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

Partager via