THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- SQL
DISTINCT
keyword, java.util.stream.Stream distinct()
method,- .NET LINQ
Distinct
method, Apache Spark's
distinct()
Code Block KTable<Windowed<K>, V> distinct(final Named named); KTable<Windowed<K>, V> distinct(final Materialized<K, V, WindowStore<Byteslanguage java firstline 1 ,
byte[]>> materialized); KTable<Windowed<K>, V> distinct(final Named named, final Materialized<K, V, WindowStore<Bytes, byte[]>> materialized);,
- Hazelcast Jet's
distinct()
, etc. etc.
...
The following methods are added to the corresponding interfaces:
Code Block | ||||
---|---|---|---|---|
| ||||
KTable<Windowed<K>, V> distinct(final Named named);
KTable<Windowed<K>, V> distinct(final Materialized<K, V, WindowStore<Bytes, byte[]>> materialized);
KTable<Windowed<K>, V> distinct(final Named named,
final Materialized<K, V, WindowStore<Bytes, byte[]>> materialized); |
The distinct operation returns only a first record that falls into a new window, and filters out all the other records that fall into an already existing window.
...