Class KGroupedTable<K, V, TJVMK, TJVMV>
KNet extension of KGroupedTable<K, V>
public class KGroupedTable<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier
Type Parameters
K
V
TJVMK
The JVM type of
K
TJVMV
The JVM type of
V
- Inheritance
-
KGroupedTable<K, V, TJVMK, TJVMV>
- Implements
- Inherited Members
Methods
Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>)
public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V
Parameters
arg0
Initializer<VR, TJVMVR>arg1
Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg2
Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>
Returns
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg2objectSuperK
K
Arg2objectSuperV
V
Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)
public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V
Parameters
arg0
Initializer<VR, TJVMVR>arg1
Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg2
Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg3
Materialized<K, VR, TJVMK, TJVMVR>
Returns
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg2objectSuperK
K
Arg2objectSuperV
V
Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Named)
public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V
Parameters
arg0
Initializer<VR, TJVMVR>arg1
Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg2
Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg3
Named
Returns
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg2objectSuperK
K
Arg2objectSuperV
V
Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)
public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Named arg3, Materialized<K, VR, TJVMK, TJVMVR> arg4) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V
Parameters
arg0
Initializer<VR, TJVMVR>arg1
Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg2
Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>arg3
Namedarg4
Materialized<K, VR, TJVMK, TJVMVR>
Returns
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg2objectSuperK
K
Arg2objectSuperV
V
Count()
public KTable<K, long, TJVMK, Long> Count()
Returns
Count(CountingMaterialized<K, TJVMK>)
public KTable<K, long, TJVMK, Long> Count(CountingMaterialized<K, TJVMK> arg0)
Parameters
arg0
CountingMaterialized<K, TJVMK>
Returns
Count(Named)
public KTable<K, long, TJVMK, Long> Count(Named arg0)
Parameters
Returns
Count(Named, CountingMaterialized<K, TJVMK>)
public KTable<K, long, TJVMK, Long> Count(Named arg0, CountingMaterialized<K, TJVMK> arg1)
Parameters
arg0
Namedarg1
CountingMaterialized<K, TJVMK>
Returns
Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1)
Parameters
Returns
Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)
Parameters
arg0
Reducer<V, TJVMV>arg1
Reducer<V, TJVMV>arg2
Materialized<K, V, TJVMK, TJVMV>
Returns
Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1, Named arg2, Materialized<K, V, TJVMK, TJVMV> arg3)
Parameters
arg0
Reducer<V, TJVMV>arg1
Reducer<V, TJVMV>arg2
Namedarg3
Materialized<K, V, TJVMK, TJVMV>
Returns
Operators
implicit operator KGroupedTable<TJVMK, TJVMV>(KGroupedTable<K, V, TJVMK, TJVMV>)
Converter from KGroupedTable<K, V, TJVMK, TJVMV> to KGroupedTable<K, V>
public static implicit operator KGroupedTable<TJVMK, TJVMV>(KGroupedTable<K, V, TJVMK, TJVMV> t)
Parameters
t
KGroupedTable<K, V, TJVMK, TJVMV>
Returns
- KGroupedTable<TJVMK, TJVMV>