THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
class DistinctParameters<K, V, I> extends Named { /** Windowing parameters only. {@code (k,v)-k} id extractor is assumed, and a persistent store with key serde is used*/ public static <K, V> DistinctParameters<K, V, K> with(final TimeWindows timeWindows); /** Windowing parameters, ID extractor, and a serde for unique IDs. Store persistency is assumedA persistent store will be used.*/ public static <K, V, I> DistinctParameters<K, V, I> with(final TimeWindows timeWindows, final KeyValueMapper<K, V, I> idExtractor, final Serde<I> idSerde); /** Windowing parameters, ID extractor, a serde for unique IDs, and a flag showing whether the {@code WindowStore} should be * persistent or not.*/ public static <K, V, I> DistinctParameters<K, V, I> with(final TimeWindows timeWindows, final KeyValueMapper<K, V, I> idExtractor, final Serde<I> idSerde, final boolean isPersistent) } |
...