跳转至

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): 右数据集在数据驱逐前缓存的时间值和单位。
    元组\<字面量\<长整型>, 枚举\<天, 小时, 毫秒, 分钟, 秒, 周>>