INTO (Azure Stream Analytics)

  • Artigo

INTO (Fluxo de Saída)

INTO especifica explicitamente um fluxo de saída e é sempre associado a uma expressão SELECT. Se não for especificado, o fluxo de saída padrão será “output”.

Sintaxe

[ INTO <output_stream> ]

Argumentos

output_stream

Especifica o nome de um fluxo de saída.

Limitações e Restrições

Você não pode usar SELECT... INTO em uma cláusula WITH. Por exemplo, a cláusula INTO pode apenas ser usada na subconsulta mais externa.

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 Fragmentos)

INTO especifica explicitamente o número de fragmentos em uma etapa de entrada ao especificar um esquema de particionamento (PARTITION BY). Se a contagem de partições não for especificada, o número de fragmentos será carregado se PARTITION BY for o mesmo ou dois, caso contrário.

INTO é uma dica 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 fragmentos na etapa upstream.

Limitações e restrições INTO

A contagem de fragmentos deve ser maior que 1. Ao ingressar vários fluxos, a contagem de partição de todas as entradas deve ser a mesma.

Exemplo INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId