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