THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
distinct
DSLOperation on aKStream<K, V>
DSLObject which returns anotherKStream<K, V>
DSLObject,DistinctParameters<K, V, I>
DSLParameter.
The type parameters are:
K
— key typeV
— , value typeI
— and the type of the record's unique identifier.
With DistinctParameters<K, V, I>
the following can be provided:
...