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 eventupdate in this KTablKTable will update produceall n consecutivematching eventsrecords, an update * in other table will update only the 1one matchedmatching 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 joinPrefixFaker a {@code ValueMapper} returning an outputkey that when serialized only produces the * prefix of the output key which is the same as serializing K * @param leftKeyExtractor a {@code ValueMapper} extracting the Key of this table from the resulting Key * @param <K0> the resultings tables Key * @param <V0> the resultings tables Value * @param joiner * @return */ <K0, V0, KO, VO> KTable<K0, V0> oneToManyJoin(KTable<KO, VO> other, ValueMapper<VO, K> keyExtractor, ValueMapper<K, K0> joinPrefixFaker, ValueMapper<K0, K> leftKeyExtractor, ValueJoiner<V, VO, V0> joiner, Serde<KO> keyOtherSerde, Serde<VO> valueOtherSerde, Serde<K0> joinKeySerde, Serde<V0> joinValueSerde); |
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * * Joins one record of this KTable to n records of the other KTable, * an eventupdate in this KTablKTable will update produceall n consecutivematching eventsrecords, an update * in other table will update only the 1one matchedmatching 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); |
...