INTO(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