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