INTO (Azure Stream Analytics)

Статья
08/02/2024

INTO (выходной поток)

Оператор INTO явно указывает поток вывода и всегда связан с выражением SELECT. Если он не задан, используется выходной поток по умолчанию — "output".

Синтаксис

[ INTO <output_stream> ]

Аргументы

output_stream

Указывает имя выходного потока.

Ограничения

Вы не можете использовать SELECT ... INTO в предложении WITH. Например, предложение INTO может использоваться только в самом крайнем вложенном запросе.

Пример

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 (количество сегментов)

INTO явно указывает количество сегментов на шаге ввода при указании схемы секционирования (PARTITION BY). Если число секционирований не указано, количество сегментов переносится, если параметр PARTITION BY совпадает или два в противном случае.

INTO является подсказкой для системы и может быть проигнорирована, если система определит, что явная спецификация не является полезной.

Синтаксис INTO

[ INTO <shard_count> ]

Аргументы INTO

shard_count

Указывает количество сегментов на шаге вышестоящий.

Ограничения INTO

Количество сегментов должно быть больше 1. При объединении нескольких потоков количество секций для всех входных данных должно быть одинаковым.

Пример INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Поделиться через