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