THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/** * {@code SessionWindowedCogroupKStream} is an abstraction of a <i>windowed</i> record stream of {@link org.apache.kafka.streams.KeyValue} pairs. * It is an intermediate representation of a {@link KGroupedStream} in order to apply a windowed aggregation operation on the original * {@link KGroupedStream} records. * <p> * It is an intermediate representation after a grouping, cogrouping and windowing of a {@link KStream} before an aggregation is applied to the * new (partitioned) windows resulting in a windowed {@link KTable} * (a <emph>windowed</emph> {@code KTable} is a {@link KTable} with key type {@link Windowed Windowed<K>}. * <p> * The specified {@code SessionWindows} define the gap between windows. * The result is written into a local windowed {@link org.apache.kafka.streams.state.KeyValueStore} (which is basically an ever-updating * materialized view) that can be queried using the name provided in the {@link Materialized} instance. * * New events are added to windows until their grace period ends (see {@link TimeWindows#grace(Duration)}). * * Furthermore, updates to the store are sent downstream into a windowed {@link KTable} changelog stream, where * "windowed" implies that the {@link KTable} key is a combined key of the original record key and a window ID. * A {@code WindowedKStream} must be obtained from a {@link KGroupedStream} via {@link KGroupedStream#windowedBy(Windows)} . * * @param <K> Type of keys * @param <V> Type of values * @see KStream * @see KGroupedStream * @see CogroupedKStream */ import org.apache.kafka.streams.state.SessionStore; public interface SessionWindowedCogroupedKStream<K, V> { KTable<Windowed<K>, Vout> aggregate(final Initializer<V> initializer, final Merger<? super K, V> sessionMerger, final Materialized<K, V, SessionStore<Bytes, byte[]>> materialized); KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer, final Merger<? super K, V> sessionMerger); KTable<Windowed<K>, Vout> aggregate(final Initializer<V> initializer, final Named named, final Merger<? super K, V> sessionMerger, final Materialized<K, V, SessionStore<Bytes, byte[]>> materialized, final Named named); KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer, final Named named, final Merger<? super K, V> sessionMerger, final Named named); } |
Code Block |
---|
/** * {@code TimeWindowedCogroupKStream} is an abstraction of a <i>windowed</i> record stream of {@link org.apache.kafka.streams.KeyValue} pairs. * It is an intermediate representation of a {@link KGroupedStream} in order to apply a windowed aggregation operation on the original * {@link KGroupedStream} records. * <p> * It is an intermediate representation after a grouping, cogrouping and windowing of a {@link KStream} before an aggregation is applied to the * new (partitioned) windows resulting in a windowed {@link KTable} * (a <emph>windowed</emph> {@code KTable} is a {@link KTable} with key type {@link Windowed Windowed<K>}. * <p> * The specified {@code windows} define either hopping time windows that can be overlapping or tumbling (c.f. * {@link TimeWindows}) or they define landmark windows (c.f. {@link UnlimitedWindows}). * The result is written into a local windowed {@link org.apache.kafka.streams.state.KeyValueStore} (which is basically an ever-updating * materialized view) that can be queried using the name provided in the {@link Materialized} instance. * * New events are added to windows until their grace period ends (see {@link TimeWindows#grace(Duration)}). * * Furthermore, updates to the store are sent downstream into a windowed {@link KTable} changelog stream, where * "windowed" implies that the {@link KTable} key is a combined key of the original record key and a window ID. * A {@code WindowedKStream} must be obtained from a {@link KGroupedStream} via {@link KGroupedStream#windowedBy(Windows)} . * * @param <K> Type of keys * @param <T> Type of values * @see KStream * @see KGroupedStream * @see CogroupedKStream */ public interface TimeWindowedCogroupedKStream<K, V> { KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer, final Materialized<K, V, WindowStore<Bytes, byte[]>> materialized); KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer); KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer, final Named named, final Materialized<K, V, WindowStore<Bytes, byte[]>> materialized); KTable<Windowed<K>, V> aggregate(final Initializer<V> initializer, final Named named); } |
...