Table of Contents

Class KStream<K, V, TJVMK, TJVMV>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll

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>

Predicate<K, V, TJVMK, TJVMV>

Returns

KStream<K, V, TJVMK, TJVMV>

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

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KStream<K, V, TJVMK, TJVMV>

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>

Predicate<K, V, TJVMK, TJVMV>

Returns

KStream<K, V, TJVMK, TJVMV>

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

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapper<V, VR, TJVMV, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapper<V, VR, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KStream<KR, VR, TJVMKR, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<KR, VR, TJVMKR, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ForeachAction<K, V, 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>

ForeachAction<K, V, TJVMK, TJVMV>

arg1 Named

Named

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

GroupByKey()

public KGroupedStream<K, V, TJVMK, TJVMV> GroupByKey()

Returns

KGroupedStream<K, V, TJVMK, TJVMV>

KGroupedStream

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>

Grouped<K, V, TJVMK, TJVMV>

Returns

KGroupedStream<K, V, TJVMK, TJVMV>

KGroupedStream

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KGroupedStream<KR, V, TJVMKR, TJVMV>

KGroupedStream<K, V, TJVMK, 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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Grouped<KR, V, TJVMKR, TJVMV>

Grouped<K, V, TJVMK, TJVMV>

Returns

KGroupedStream<KR, V, TJVMKR, TJVMV>

KGroupedStream<K, V, TJVMK, 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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg3 Named

Named

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

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>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg3 Named

Named

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>

Joined

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

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>

Joined

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMV, TJVMGV, TJVMRV>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg3 Named

Named

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

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>

KStream<K, V, TJVMK, TJVMV>

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>

GlobalKTable<K, V, TJVMK, TJVMV>

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, TJVMK, TJVMV, TJVMGK>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV, TJVMK, TJVMV, TJVMGV, TJVMRV>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg3 Named

Named

Returns

KStream<K, RV, TJVMK, TJVMRV>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR, TJVMV, TJVMVT, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 Joined<K, V, VT, TJVMK, TJVMV, TJVMVT>

Joined

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

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>

KTable<K, V, TJVMK, TJVMV>

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>

Joined

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapper<V, VR, TJVMV, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapper<V, VR, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KStream<KR, VR, TJVMKR, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<KR, VR, TJVMKR, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

Returns

KStream<K, V, TJVMK, TJVMV>

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

arg0 KStream<K, V, TJVMK, TJVMV>

KStream<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>

ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

KStream<K, V, TJVMK, TJVMV>

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMK, TJVMV, TJVMVO, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO, TJVMK, TJVMV, TJVMVO>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

KStream<K, VR, TJVMK, TJVMVR>

KStream<K, V, TJVMK, TJVMV>

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>

ForeachAction<K, V, TJVMK, TJVMV>

Returns

KStream<K, V, TJVMK, TJVMV>

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>

ForeachAction<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KStream<K, V, TJVMK, TJVMV>

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>

Printed<K, V>

Repartition()

public KStream<K, V, TJVMK, TJVMV> Repartition()

Returns

KStream<K, V, TJVMK, TJVMV>

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>

Repartitioned<K, V, TJVMK, TJVMV>

Returns

KStream<K, V, TJVMK, TJVMV>

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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Returns

KStream<KR, V, TJVMKR, TJVMV>

KStream<K, V, TJVMK, 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>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KStream<KR, V, TJVMKR, TJVMV>

KStream<K, V, TJVMK, 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>

BranchedKStream

Split(Named)

public BranchedKStream<K, V, TJVMK, TJVMV> Split(Named arg0)

Parameters

arg0 Named

Named

Returns

BranchedKStream<K, V, TJVMK, TJVMV>

BranchedKStream

To(TopicNameExtractor<K, V, TJVMK, TJVMV>)

public void To(TopicNameExtractor<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 TopicNameExtractor<K, V, TJVMK, TJVMV>

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>

TopicNameExtractor<K, V, TJVMK, TJVMV>

arg1 Produced<K, V, TJVMK, TJVMV>

Produced<K, V, TJVMK, TJVMV>

To(string)

public void To(string arg0)

Parameters

arg0 string

string

To(string, Produced<K, V, TJVMK, TJVMV>)

public void To(string arg0, Produced<K, V, TJVMK, TJVMV> arg1)

Parameters

arg0 string

string

arg1 Produced<K, V, TJVMK, TJVMV>

Produced<K, V>

ToTable()

public KTable<K, V, TJVMK, TJVMV> ToTable()

Returns

KTable<K, V, TJVMK, TJVMV>

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>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

ToTable(Named)

public KTable<K, V, TJVMK, TJVMV> ToTable(Named arg0)

Parameters

arg0 Named

Named

Returns

KTable<K, V, TJVMK, TJVMV>

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 Named

Named

arg1 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Operators

implicit operator KStream<TJVMK, TJVMV>(KStream<K, V, TJVMK, TJVMV>)

public static implicit operator KStream<TJVMK, TJVMV>(KStream<K, V, TJVMK, TJVMV> t)

Parameters

t KStream<K, V, TJVMK, TJVMV>

Returns

KStream<TJVMK, TJVMV>