join 运算符

• 04/07/2021
• • o
  • a
  • v

通过匹配每个表中指定列的值，合并两个表的行以组成新表。

Table1 | join (Table2) on CommonColumn, $left.Col1 == $right.Col2

语法

LeftTable | join [JoinParameters] ( RightTable ) on Attributes

参数

• LeftTable：要合并其行的 左侧 表或表格表达式（有时称为 外部 表）。 表示为 $left。

• RightTable：要合并其行的 右侧 表或表格表达式（有时称为 内部 表）。 表示为 $right。

• Attributes：一个或多个逗号分隔的规则，这些规则描述 LeftTable 中的行如何与 RightTable 中的行进行匹配。 将使用 and 逻辑运算符评估多个规则。

  规则 可以是下列项之一：

  规则类型	语法	Predicate
  基于名称的等式	ColumnName	where LeftTable.ColumnName == RightTable.ColumnName
  基于值的等式	$left.LeftColumn == $right.RightColumn	where $left.LeftColumn == $right.RightColumn

  备注

  如果使用“基于值的等式”，则列名称必须通过由 $left 和 $right 表示法表示的相应的所有者表进行限定。

• JoinParameters：零个或零个以上（以空格分隔）以 Name = Value 形式表示的参数，用于控制行匹配操作和执行计划的行为 。 支持以下参数：

  参数名称	值	说明
  kind	联接风格	请参阅联接风格
  hint.remote	auto, left, local, right	请参阅跨群集联接
  hint.strategy	执行提示	请参阅联接提示

  名称	值	说明
  kind	联接风格	请参阅联接风格
  hint.remote	auto, left, local, right
  hint.strategy	执行提示	请参阅联接提示

返回

输出架构取决于联接风格：

输出记录取决于联接风格：

示例

从 login 中获取扩展活动，某些条目将其标记为活动的开始和结束。

let Events = MyLogTable | where type=="Event" ;
Events
| where Name == "Start"
| project Name, City, ActivityId, StartTime=timestamp
| join (Events
    | where Name == "Stop"
        | project StopTime=timestamp, ActivityId)
    on ActivityId
| project City, ActivityId, StartTime, StopTime, Duration = StopTime - StartTime

let Events = MyLogTable | where type=="Event" ;
Events
| where Name == "Start"
| project Name, City, ActivityIdLeft = ActivityId, StartTime=timestamp
| join (Events
        | where Name == "Stop"
        | project StopTime=timestamp, ActivityIdRight = ActivityId)
    on $left.ActivityIdLeft == $right.ActivityIdRight
| project City, ActivityId, StartTime, StopTime, Duration = StopTime - StartTime

联接风格

join 运算符的确切风格是通过 kind 关键字指定的。 支持 join 运算符的以下风格：

默认联接风格

默认联接风格是在左侧删除了重复数据的内联。 在典型的日志/跟踪分析方案中，默认联接实现非常有用。在这种方案中，你想要关联两个事件，每个事件都在同一个相关 ID 下匹配某个筛选条件。 你需要获取所有出现的现象，忽略多次出现的构成跟踪记录。

X | join Y on Key
 
X | join kind=innerunique Y on Key

下面的两个示例表用来说明联接操作。

表 X

表 Y

默认联接在左侧对联接键执行重复数据删除后（删除重复数据时会保留第一个记录）执行内联。

对于以下语句：X | join Y on Key

联接的有效左侧（删除重复数据后的表 X）将是：

联接结果将是：

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join Y on Key

内联风格

内联函数类似于 SQL 中的标准内联。 只要左侧的记录具有与右侧记录相同的联接键，就会生成输出记录。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=inner Y on Key

Innerunique 联接风格

使用 innerunique 联接风格 从左侧删除重复键。 结果将是进行了重复数据删除的左键和右键的每种组合在输出中存在一行。

let t1 = datatable(key:long, value:string)  
[
1, "val1.1",  
1, "val1.2"  
];
let t2 = datatable(key:long, value:string)  
[  
1, "val1.3",
1, "val1.4"  
];
t1
| join kind = innerunique
    t2
on key

let t1 = datatable(key:long, value:string)  
[
1, "val1.1",  
1, "val1.2"  
];
let t2 = datatable(key:long, value:string)  
[  
1, "val1.3", 
1, "val1.4"  
];
t1
| join kind = innerunique
    t2
on key

• Kusto 经过优化，它会尽可能将 join 之后的筛选器推向相应的联接端，不管是左侧还是右侧。

• 有时，使用的风格是 innerunique，并且筛选器将传播到联接的左侧。 风格会自动传播，应用于该筛选器的键会始终出现在输出中。

• 使用上面的示例，添加筛选器 where value == "val1.2" 。 它将始终提供第二个结果，永远不会为数据集提供第一个结果：

let t1 = datatable(key:long, value:string)  
[
1, "val1.1",  
1, "val1.2"  
];
let t2 = datatable(key:long, value:string)  
[  
1, "val1.3", 
1, "val1.4"  
];
t1
| join kind = innerunique
    t2
on key
| where value == "val1.2"

左外部联接风格

表 X 和 Y 的左外部联接的结果始终包含左表 (X) 的所有记录，即使联接条件在右表 (Y) 中未找到任何匹配记录。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=leftouter Y on Key

右外部联接风格

右外部联接风格与左外部联接类似，但对表的处理是相反的。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=rightouter Y on Key

完全外部联接风格

完全外部联接合并了应用左外部联接和右外部联接的效果。 如果联接的表中的记录不匹配，则对于表中缺少匹配行的每个列，结果集都会有 null 值。 对于那些匹配的记录，结果集中会生成单个行（其中包含两个表中填充的字段）。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=fullouter Y on Key

左反联接风格

左反联接返回左侧中在右侧没有任何匹配记录的所有记录。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=leftanti Y on Key

右反联接风格

右反联接返回右侧中在左侧没有任何匹配记录的所有记录。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=rightanti Y on Key

左半联接风格

左半联接返回左侧中在右侧具有匹配记录的所有记录。 仅会返回左侧的列。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=leftsemi Y on Key

右半联接风格

右半联接返回右侧中在左侧具有匹配记录的所有记录。 仅会返回右侧的列。

let X = datatable(Key:string, Value1:long)
[
    'a',1,
    'b',2,
    'b',3,
    'c',4
];
let Y = datatable(Key:string, Value2:long)
[
    'b',10,
    'c',20,
    'c',30,
    'd',40
];
X | join kind=rightsemi Y on Key

交叉联接

Kusto 本身不提供交叉联接风格。 无法用 kind=cross 来标记运算符。 若要进行模拟，请使用虚拟键。

X | extend dummy=1 | join kind=inner (Y | extend dummy=1) on dummy

联接提示

join 运算符支持许多用于控制查询运行方式的提示。 这些提示不会更改 join 的语义，但可能会影响其性能。

以下文章解释了联接提示：

• hint.shufflekey=<key> 和 hint.strategy=shuffle - 随机执行查询
• hint.strategy=broadcast - 广播联接
• hint.remote=<strategy> - 跨群集联接