INTO（Azure 流分析）

项目
08/02/2024

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

通过