THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/**
*
* Joins one record of this KTable to n records of the other KTable,
* an update in this KTable will update all n matching records, an update
* in other table will update only the one matching record.
*
* @param the table containing n records for each K of this table
* @param keyExtractor a {@code ValueMapper} returning the key of this table from the others value
* @param leftKeyExtractor a {@code ValueMapper} extracting the Key of this table from the resulting Key
* @param <V0> the resultings tables Value
* @param joiner
* @return
*/
<CombinedKey<K,KO>, V0, KO, VO> KTable <V0> oneToManyJoin(KTable<KO, VO> other,
ValueMapper<VO, K> keyExtractor,
ValueJoiner<V, VO, V0> joiner,
Serde<KO> keyOtherSerde, Serde<VO> valueOtherSerde,
Serde<K0> joinKeySerde, Serde<V0> joinValueSerde); |
...