INTO (Azure Stream Analytics)

Artigo
08/02/2024

INTO (Fluxo de Saída)

INTO especifica explicitamente um fluxo de saída e está sempre associado a uma expressão SELECT. Se não for especificado, o fluxo de saída predefinido é "output".

Sintaxe

[ INTO <output_stream> ]

Argumentos

output_stream

Especifica o nome de um fluxo de saída.

Limitações e Restrições

Não pode utilizar SELECT... INTO numa cláusula WITH. Por exemplo, a cláusula INTO só pode ser utilizada na subconsulta mais frequente.

Exemplo

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 (Contagem de Partições Horizontais)

INTO especifica explicitamente o número de partições horizontais num passo de entrada ao especificar um esquema de criação de partições (PARTIÇÃO POR). Se a contagem de partições não for especificada, o número de partições horizontais será transitado se a PARTIÇÃO POR for igual ou duas de outra forma.

INTO é uma sugestão para o sistema e pode ser ignorado caso o sistema determine que a especificação explícita não é benéfica.

Sintaxe INTO

[ INTO <shard_count> ]

Argumentos INTO

shard_count

Especifica o número de partições horizontais no passo a montante.

Limitações e Restrições do INTO

A contagem de partições horizontais tem de ser superior a 1. Ao associar vários fluxos, a contagem de partições de todas as entradas tem de ser a mesma.

Exemplo INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Partilhar via