Versions Compared

Key

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

...

Code Block
<V0, KL, VL, KR, VR> KTable<KL, V0> foreignKeyJoin(KTable<KR, VR> other,
                                                    ValueMapper<VL, KR> foreignKeyExtractor,
                                                    final ValueJoiner<VR, VL, V0> joiner,
                                                    final Materialized<KL, V0, KeyValueStore<Bytes, byte[]>> materialized,
                                                    Serde<KL> thisKeySerde,
                                                    Serde<KR> otherKeySerde,
                                                    Serde<VR> otherValueSerde,
                                                    Serde<V0> joinedValueSerde);


Workflows

Overview

Gliffy Diagram
nameBellemareOverview213
pagePin2


CombinedKeys Usage by Left Processor

Gliffy Diagram
nameLeftProcessingWithCombinedKey
pagePin2

CombinedKeys Usage by RangeScan Processor




PrefixScan on CombinedKey


Handling out-of-order processing of rekeyed data