进入

✅ Azure 流分析 ✅ 构造事件流

INTO (输出流)

INTO 显式指定输出流,并且始终与 SELECT 表达式相关联。 如果未指定,则默认输出流为“output”。

语法

[ 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