Class KStream<K, V, TJVMK, TJVMV>
KNet extension of KStream<K, V>
public class KStream<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier
Type Parameters
K
V
TJVMK
The JVM type of
K
TJVMV
The JVM type of
V
- Inheritance
-
KStream<K, V, TJVMK, TJVMV>
- Implements
- Inherited Members
Methods
FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named)
public KStream<K, V, TJVMK, TJVMV> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named)
public KStream<K, V, TJVMK, TJVMV> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
FlatMapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> FlatMapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0) where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperV
V
Arg0ExtendsVR
VR
FlatMapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>, Named)
public KStream<K, VR, TJVMK, TJVMVR> FlatMapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>arg1
Named
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperV
V
Arg0ExtendsVR
VR
FlatMapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> FlatMapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVR
VR
FlatMapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>, Named)
public KStream<K, VR, TJVMK, TJVMVR> FlatMapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>arg1
Named
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVR
VR
FlatMap<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>)
public KStream<KR, VR, TJVMKR, TJVMVR> FlatMap<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>
Returns
- KStream<KR, VR, TJVMKR, TJVMVR>
Type Parameters
KR
VR
TJVMKR
The JVM type of
KR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
Arg0ExtendsVR
VR
FlatMap<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>, Named)
public KStream<KR, VR, TJVMKR, TJVMVR> FlatMap<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR
Parameters
arg0
EnumerableKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>arg1
Named
Returns
- KStream<KR, VR, TJVMKR, TJVMVR>
Type Parameters
KR
VR
TJVMKR
The JVM type of
KR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
Arg0ExtendsVR
VR
Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>)
public void Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named)
public void Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>arg1
Named
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
GroupByKey()
public KGroupedStream<K, V, TJVMK, TJVMV> GroupByKey()
Returns
- KGroupedStream<K, V, TJVMK, TJVMV>
GroupByKey(Grouped<K, V, TJVMK, TJVMV>)
public KGroupedStream<K, V, TJVMK, TJVMV> GroupByKey(Grouped<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
Grouped<K, V, TJVMK, TJVMV>
Returns
- KGroupedStream<K, V, TJVMK, TJVMV>
GroupBy<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR>)
public KGroupedStream<KR, V, TJVMKR, TJVMV> GroupBy<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR>
Returns
- KGroupedStream<KR, V, TJVMKR, TJVMV>
Type Parameters
KR
TJVMKR
The JVM type of
KR
Arg0objectSuperK
K
Arg0objectSuperV
V
GroupBy<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR>, Grouped<KR, V, TJVMKR, TJVMV>)
public KGroupedStream<KR, V, TJVMKR, TJVMV> GroupBy<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR> arg0, Grouped<KR, V, TJVMKR, TJVMV> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR, TJVMK, TJVMV, TJVMKR>arg1
Grouped<KR, V, TJVMKR, TJVMV>
Returns
- KGroupedStream<KR, V, TJVMKR, TJVMV>
Type Parameters
KR
TJVMKR
The JVM type of
KR
Arg0objectSuperK
K
Arg0objectSuperV
V
Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>)
public KStream<K, RV, TJVMK, TJVMRV> Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>, Named)
public KStream<K, RV, TJVMK, TJVMRV> Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>arg3
Named
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>)
public KStream<K, RV, TJVMK, TJVMRV> Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>, Named)
public KStream<K, RV, TJVMK, TJVMRV> Join<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg3
Named
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR> arg1, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT> arg2) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>arg2
Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>)
public KStream<K, VR, TJVMK, TJVMVR> Join<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR> arg1, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>)
public KStream<K, RV, TJVMK, TJVMRV> LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>, Named)
public KStream<K, RV, TJVMK, TJVMRV> LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>arg3
Named
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>)
public KStream<K, RV, TJVMK, TJVMRV> LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>, Named)
public KStream<K, RV, TJVMK, TJVMRV> LeftJoin<RV, GK, GV, TJVMRV, TJVMGK, TJVMGV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV, TJVMGK, TJVMGV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV
Parameters
arg0
GlobalKTable<GK, GV, TJVMGK, TJVMGV>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg3
Named
Returns
- KStream<K, RV, TJVMK, TJVMRV>
Type Parameters
RV
GK
GV
TJVMRV
The JVM type of
RV
TJVMGK
The JVM type of
GK
TJVMGV
The JVM type of
GV
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGK
GK
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGV
GV
Arg2ExtendsRV
RV
LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR> arg1, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT> arg2) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>arg2
Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>)
public KStream<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VT, TJVMVR, TJVMVT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT, TJVMK, TJVMVT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR> arg1, Joined<K, V, VT, TJVMK, TJVMV, TJVMVT> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR
Parameters
arg0
KTable<K, VT, TJVMK, TJVMVT>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVT, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VT
TJVMVR
The JVM type of
VR
TJVMVT
The JVM type of
VT
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVT
VT
Arg1ExtendsVR
VR
MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0) where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperV
V
Arg0ExtendsVR
VR
MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>, Named)
public KStream<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>arg1
Named
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperV
V
Arg0ExtendsVR
VR
MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>)
public KStream<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVR
VR
MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>, Named)
public KStream<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>arg1
Named
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVR
VR
Map<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>)
public KStream<KR, VR, TJVMKR, TJVMVR> Map<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR
Parameters
arg0
KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>
Returns
- KStream<KR, VR, TJVMKR, TJVMVR>
Type Parameters
KR
VR
TJVMKR
The JVM type of
KR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
Arg0ExtendsVR
VR
Map<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>, Named)
public KStream<KR, VR, TJVMKR, TJVMVR> Map<KR, VR, TJVMKR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR
Parameters
arg0
KeyValueKeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, Arg0ExtendsVR, TJVMK, TJVMV, TJVMKR, TJVMVR>arg1
Named
Returns
- KStream<KR, VR, TJVMKR, TJVMVR>
Type Parameters
KR
VR
TJVMKR
The JVM type of
KR
TJVMVR
The JVM type of
VR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
Arg0ExtendsVR
VR
Merge(KStream<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Merge(KStream<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
KStream<K, V, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Merge(KStream<K, V, TJVMK, TJVMV>, Named)
public KStream<K, V, TJVMK, TJVMV> Merge(KStream<K, V, TJVMK, TJVMV> arg0, Named arg1)
Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows)
public KStream<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindows
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>, JoinWindows, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>)
public KStream<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO, TJVMK, TJVMVO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR
Parameters
arg0
KStream<K, VO, TJVMK, TJVMVO>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
arg2
JoinWindowsarg3
StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>
Returns
- KStream<K, VR, TJVMK, TJVMVR>
Type Parameters
VR
VO
TJVMVR
The JVM type of
VR
TJVMVO
The JVM type of
VO
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVO
VO
Arg1ExtendsVR
VR
Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named)
public KStream<K, V, TJVMK, TJVMV> Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
ForeachAction<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>arg1
Named
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Print(Printed<K, V, TJVMK, TJVMV>)
public void Print(Printed<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
Printed<K, V, TJVMK, TJVMV>
Repartition()
public KStream<K, V, TJVMK, TJVMV> Repartition()
Returns
- KStream<K, V, TJVMK, TJVMV>
Repartition(Repartitioned<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Repartition(Repartitioned<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
Repartitioned<K, V, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
SelectKey<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>)
public KStream<KR, V, TJVMKR, TJVMV> SelectKey<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>
Returns
- KStream<KR, V, TJVMKR, TJVMV>
Type Parameters
KR
TJVMKR
The JVM type of
KR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
SelectKey<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>, Named)
public KStream<KR, V, TJVMKR, TJVMV> SelectKey<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>arg1
Named
Returns
- KStream<KR, V, TJVMKR, TJVMV>
Type Parameters
KR
TJVMKR
The JVM type of
KR
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKR
KR
Split()
public BranchedKStream<K, V, TJVMK, TJVMV> Split()
Returns
- BranchedKStream<K, V, TJVMK, TJVMV>
Split(Named)
public BranchedKStream<K, V, TJVMK, TJVMV> Split(Named arg0)
Parameters
Returns
- BranchedKStream<K, V, TJVMK, TJVMV>
To(TopicNameExtractor<K, V, TJVMK, TJVMV>)
public void To(TopicNameExtractor<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
TopicNameExtractor<K, V, TJVMK, TJVMV>
To(TopicNameExtractor<K, V, TJVMK, TJVMV>, Produced<K, V, TJVMK, TJVMV>)
public void To(TopicNameExtractor<K, V, TJVMK, TJVMV> arg0, Produced<K, V, TJVMK, TJVMV> arg1)
Parameters
arg0
TopicNameExtractor<K, V, TJVMK, TJVMV>arg1
Produced<K, V, TJVMK, TJVMV>
To(string)
public void To(string arg0)
Parameters
To(string, Produced<K, V, TJVMK, TJVMV>)
public void To(string arg0, Produced<K, V, TJVMK, TJVMV> arg1)
Parameters
ToTable()
public KTable<K, V, TJVMK, TJVMV> ToTable()
Returns
- KTable<K, V, TJVMK, TJVMV>
ToTable(Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> ToTable(Materialized<K, V, TJVMK, TJVMV> arg0)
Parameters
arg0
Materialized<K, V, TJVMK, TJVMV>
Returns
- KTable<K, V, TJVMK, TJVMV>
ToTable(Named)
public KTable<K, V, TJVMK, TJVMV> ToTable(Named arg0)
Parameters
Returns
- KTable<K, V, TJVMK, TJVMV>
ToTable(Named, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> ToTable(Named arg0, Materialized<K, V, TJVMK, TJVMV> arg1)
Parameters
arg0
Namedarg1
Materialized<K, V, TJVMK, TJVMV>
Returns
- KTable<K, V, TJVMK, TJVMV>
Operators
implicit operator KStream<TJVMK, TJVMV>(KStream<K, V, TJVMK, TJVMV>)
Converter from KStream<K, V, TJVMK, TJVMV> to KStream<K, V>
public static implicit operator KStream<TJVMK, TJVMV>(KStream<K, V, TJVMK, TJVMV> t)
Parameters
t
KStream<K, V, TJVMK, TJVMV>
Returns
- KStream<TJVMK, TJVMV>