Skip to content

Commit

Permalink
naming change
Browse files Browse the repository at this point in the history
  • Loading branch information
jeremyvdw committed Dec 22, 2023
1 parent 0b203f2 commit b1ac489
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/jackdaw/streams/interop.clj
Original file line number Diff line number Diff line change
Expand Up @@ -164,13 +164,13 @@

(join
[_ ktable value-joiner-fn
{key-serde :key-serde this-value-serde :value-serde name :name}
{key-serde :key-serde this-value-serde :value-serde joined-name :name}
{other-value-serde :value-serde}]
(clj-kstream
(.join ^KStream kstream
^KTable (ktable* ktable)
^ValueJoiner (value-joiner value-joiner-fn)
^Joined (->joined key-serde this-value-serde other-value-serde name))))
^Joined (->joined key-serde this-value-serde other-value-serde joined-name))))

(left-join
[_ ktable value-joiner-fn]
Expand Down

0 comments on commit b1ac489

Please sign in to comment.