Class TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
KNet extension of TimeWindowedCogroupedKStream<K, V>
public class TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier
Type Parameters
K
V
TJVMK
The JVM type of
K
TJVMV
The JVM type of
V
- Inheritance
-
TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
- Implements
- Inherited Members
Methods
Aggregate(Initializer<V, TJVMV>)
public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0)
Parameters
arg0
Initializer<V, TJVMV>
Returns
Aggregate(Initializer<V, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Materialized<K, V, TJVMK, TJVMV> arg1)
Parameters
arg0
Initializer<V, TJVMV>arg1
Materialized<K, V, TJVMK, TJVMV>
Returns
Aggregate(Initializer<V, TJVMV>, Named)
public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Named arg1)
Parameters
arg0
Initializer<V, TJVMV>arg1
Named
Returns
Aggregate(Initializer<V, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Named arg1, Materialized<K, V, TJVMK, TJVMV> arg2)
Parameters
arg0
Initializer<V, TJVMV>arg1
Namedarg2
Materialized<K, V, TJVMK, TJVMV>
Returns
Operators
implicit operator TimeWindowedCogroupedKStream<TJVMK, TJVMV>(TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>)
Converter from TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV> to TimeWindowedCogroupedKStream<K, V>
public static implicit operator TimeWindowedCogroupedKStream<TJVMK, TJVMV>(TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV> t)
Parameters
t
TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
Returns
- TimeWindowedCogroupedKStream<TJVMK, TJVMV>