...
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 customCombinedKey a {@code ValueMapper} allowing the CombinedKey to be wrapped in a custom object * @param combinedKey a {@code ValueMapper} allowing to unwrap the custom object again. * @param <VO> the resultings tables Value * @param joiner * @return */ <KO VO, K1, V1> KTable<KO,VO> oneToManyJoin(KTable<K1, V1> other, ValueMapper<V1, K> keyExtractor, ValueMapper<CombinedKey<K1,K>,KO> customCombinedKeyoutputKeyCombiner, ValueMapper<KO,CombinedKey<K1,K>> combinedKeyoutputKeySpliter, ValueJoiner<V, V1, VO> joiner, Serde<K1> keyOtherSerde, Serde<V1> valueOtherSerde, Serde<VO> joinValueSerde); |
...