Outer caching join(外缓存连接(Outer caching join))¶
Supported in: Streaming
Rows from the left & right inputs which meet all of the match conditions and are within the caching window, along with unmatched rows from both inputs.
Transform categories: Join
Declared arguments¶
- Default cache time unit: Default unit for amount of time data will be cached for before eviction for both the lhs and rhs cache.
Enum\ - Default cache time value: Default value for the amount of time data will be cached for before eviction for both the lhs and rhs cache.
Literal\ - Join key: A list of columns from left and right input to join on.
List\, Column\\ >> - Left columns to keep: Left columns to keep.
List\> - Left dataset: Left dataset to use in join.
Table - Right columns to keep: Right columns to keep.
List\> - Right dataset: Right dataset to use in join.
Table - optional Prefix for columns from right: Prefix for columns from right.
Literal\ - optional Rhs cache time override: Value and unit of time that data from the rhs dataset will be cached for before eviction.
Tuple\, Enum\\ >
中文翻译¶
外缓存连接(Outer caching join)¶
支持:流式处理(Streaming)
左输入与右输入中满足所有匹配条件且在缓存窗口内的行,以及两个输入中未匹配的行。
转换类别:连接(Join)
声明的参数¶
- 默认缓存时间单位(Default cache time unit): 左缓存和右缓存在数据驱逐前默认缓存的时间单位。
枚举\<天, 小时, 毫秒, 分钟, 秒, 周> - 默认缓存时间值(Default cache time value): 左缓存和右缓存在数据驱逐前默认缓存的时间值。
字面量\<长整型> - 连接键(Join key): 用于连接的左输入和右输入中的列列表。
列表\<元组\<列\<任意类型>, 列\<任意类型>>> - 保留的左列(Left columns to keep): 需要保留的左列。
列表\<列\<任意类型>> - 左数据集(Left dataset): 用于连接的左数据集。
表 - 保留的右列(Right columns to keep): 需要保留的右列。
列表\<列\<任意类型>> - 右数据集(Right dataset): 用于连接的右数据集。
表 - 可选 右列前缀(Prefix for columns from right): 来自右列的前缀。
字面量\<字符串> - 可选 右缓存时间覆盖(Rhs cache time override): 右数据集在数据驱逐前缓存的时间值和单位。
元组\<字面量\<长整型>, 枚举\<天, 小时, 毫秒, 分钟, 秒, 周>>