Versions Compared

Old Version 9

changes.mady.by.user guozhang Wang

Saved on

compared with

New Version Current

changes.mady.by.user guozhang Wang

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
KTable<KA, VA> tableA = builder.table("topicA");
 
KTable<KB, VB> tableB = builder.table("topicB");    // assuming topicB's message value payload contains field of "KA"

KTbale<KB, VR> tableR = tableB.join(tableA, (keyB, valueB) -> valueB.get("fieldKA"), (keyB, keyA) -> combine(keyB, keyA), (valueA, valueB) -> joined);   // join return type "KRVR"

 

Non-window to Window Table Join

...