流分析

Question

是否可以在流分析中包含多个输入源？我想将不同的列输出到同一个输出中，但是，它不允许我使用相同的输出名称。

这是我写的查询： with pg1 as( SELECT count(),id FROM EventHub where id='1' group by id,TumblingWindow(hour,1) ), pg2 as( SELECT count() ,id FROM EventHub where id ='2' group by id, TumblingWindow(hour,1) ) Select count() into PowerBiAlias from pg1 group by TumblingWindow(hour,1) Select count() into PowerBiAlias from pg2 group by TumblingWindow(小时,1)

Answer 1

尝试联合然后选择输出：

with 
pg1 as(
 SELECT count(),id 
 FROM EventHub
 where id='1'
 group by id,TumblingWindow(hour,1) 
), 
pg2 as(
 SELECT count() ,id
 FROM EventHub
 where id='2'
 group by id, TumblingWindow(hour,1) 
),
UnionStep as (
 Select count() as cnt from pg1 group by TumblingWindow(hour,1) 
 Union All
 Select count() as cnt from pg2 group by TumblingWindow(hour,1)
)
Select *
Into PowerBiAlias
From UnionStep