• Documentation
    • Search documentation
    karat

    +

    K

    API Reference ↗
    Data connectivity & integrationPipeline Builder TransformsOuter 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<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>
    • 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<Long>
    • Join key: A list of columns from left and right input to join on.
      List<Tuple<Column<AnyType>, Column<AnyType>>>
    • Left columns to keep: Left columns to keep.
      List<Column<AnyType>>
    • Left dataset: Left dataset to use in join.
      Table
    • Right columns to keep: Right columns to keep.
      List<Column<AnyType>>
    • Right dataset: Right dataset to use in join.
      Table
    • optional Prefix for columns from right: Prefix for columns from right.
      Literal<String>
    • optional Rhs cache time override: Value and unit of time that data from the rhs dataset will be cached for before eviction.
      Tuple<Literal<Long>, Enum<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>>