join包

join包提供了将两个表流合并在一起的函数。导入join包

import "join"

外连接

连接转换支持左连接、右连接和全外连接。

• 左外连接为左输入流中的每个记录生成至少一个输出行。如果左输入流中的记录在右输入流中没有匹配项，则r在as函数中用默认记录替换。
• 右外连接为右输入流中的每个记录生成至少一个输出行。如果右输入流中的记录在左输入流中没有匹配项，则l在as函数中用默认记录替换。
• 全外连接为两个输入流中的每个记录生成至少一个输出行。如果任一输入流中的记录在另一个输入流中没有匹配项，则as函数的一个参数用默认记录（l或r，取决于缺少匹配记录的是哪一个）替换。

默认记录与对应输入表中的记录具有相同的列，但只有分组键列填充了值。所有其他列都是null。

内连接

内连接会丢弃在另一个输入流中没有匹配项的任何记录。执行内连接时不需要考虑默认或不匹配的记录。

函数