INTO (Azure Stream Analytics)

發行項
08/02/2024

INTO (輸出資料流程)

INTO 會明確指定輸出資料流，且一律會與 SELECT 運算式相關聯。若未指定，則預設輸出資料流為「輸出」。

語法

[ INTO <output_stream> ]

引數

output_stream

指定輸出資料流的名稱。

限制事項

您無法使用 SELECT ... WITH 子句中的 INTO。例如，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

共用方式為