EM

✅ Azure Stream Analytics ✅ Fabric Eventstream

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 padrão é "saída".

Sintaxe

[ INTO <output_stream> ]  

Argumentos

output_stream

Especifica o nome de um fluxo de saída.

Limitações e Restrições

Não é possível usar SELECT ... INTO em uma cláusula COM. Por exemplo, a cláusula INTO só pode 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 estilhaços)

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á transferido se a PARTIÇÃO BY for a mesma ou duas.

INTO é uma dica para o sistema, e pode ser ignorado se o sistema determinar 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 a montante.

Limitações e restrições do INTO

A contagem de estilhaços deve ser superior a 1. Ao unir vários fluxos, a contagem de partições 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