В

✅ Поток событий Azure Stream Analytics ✅ Fabric

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

IN явно указывает количество сегментов во входном шаге при указании схемы секционирования (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