THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
KeyValueMapper<K, V, I>
idExtractor
— extracts a unique identifier from a record by which we de-duplicate input records. If it returns null, the record will not be considered for de-duping and forwarded as-is. If not provided, defaults to(key, value) -> key
, which means deduplication based on key of the record. Important assumption: records from different partitions should have different IDs, otherwise same IDs might be not co-partitioned.TimeWindows timeWindows
— tumbling or hopping time-based window specification. Required parameter. Only the first message with a given id that falls into a window will be passed downstream.Serde<I> idSerde
— serde for unique identifier.boolean isPersistent
— whether theWindowStore
that stores the unique ids should be persistent or not. In many cases, non-persistent store will be preferrable , since because of better performance. In any case, downstream consumers should be ready to accept occasional duplicates sometimes.
Proposed Changes
- Add the following method to
KStream
interface:
...