Table of Contents

Class KStream<K, V>

Namespace
Org.Apache.Kafka.Streams.Kstream
Assembly
MASES.KNet.dll
public class KStream<K, V> : JVMBridgeBase<KStream<K, V>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IKStream<K, V>

Type Parameters

K
V
Inheritance
JVMBridgeBase
JVMBridgeBase<KStream<K, V>>
KStream<K, V>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
IKStream<K, V>
Inherited Members
JVMBridgeBase<KStream<K, V>>.IsAssignableFrom(IJavaType)
JVMBridgeBase<KStream<K, V>>.IsAssignableFrom<T>()
JVMBridgeBase<KStream<K, V>>.Execute<T>(params T[])
JVMBridgeBase<KStream<K, V>>.DynBridgeClazz
JVMBridgeBase<KStream<K, V>>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

KStream()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream()

KStream(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV>)

public KStream<K, V> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV>

Predicate

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV>, Named)

public KStream<K, V> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV>

Predicate

arg1 Named

Named

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV>)

public KStream<K, V> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV>

Predicate

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV>, Named)

public KStream<K, V> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV>

Predicate

arg1 Named

Named

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

FlatMapValues<VR, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>)

public KStream<K, VR> FlatMapValues<VR, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_> arg0) where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_ : Iterable<Arg0ExtendsVR> where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>

ValueMapper

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_

Iterable<T>

Arg0ExtendsVR

VR

FlatMapValues<VR, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>, Named)

public KStream<K, VR> FlatMapValues<VR, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_ : Iterable<Arg0ExtendsVR> where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>

ValueMapper

arg1 Named

Named

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_

Iterable<T>

Arg0ExtendsVR

VR

FlatMapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>)

public KStream<K, VR> FlatMapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_ : Iterable<Arg0ExtendsVR> where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>

ValueMapperWithKey

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_

Iterable<T>

Arg0ExtendsVR

VR

FlatMapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>, Named)

public KStream<K, VR> FlatMapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_ : Iterable<Arg0ExtendsVR> where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_>

ValueMapperWithKey

arg1 Named

Named

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVR_

Iterable<T>

Arg0ExtendsVR

VR

FlatMap<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__>)

public KStream<KR, VR> FlatMap<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__ : Iterable<Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_> where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_ : KeyValue<Arg0ExtendsKR, Arg0ExtendsVR> where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__>

KeyValueMapper

Returns

KStream<KR, VR>

KStream

Type Parameters

KR
VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__

Iterable<T>

Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_

KeyValue<K, V>

Arg0ExtendsKR

KR

Arg0ExtendsVR

VR

FlatMap<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__>, Named)

public KStream<KR, VR> FlatMap<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__ : Iterable<Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_> where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_ : KeyValue<Arg0ExtendsKR, Arg0ExtendsVR> where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__>

KeyValueMapper

arg1 Named

Named

Returns

KStream<KR, VR>

KStream

Type Parameters

KR
VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR__

Iterable<T>

Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_

KeyValue<K, V>

Arg0ExtendsKR

KR

Arg0ExtendsVR

VR

Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>)

public void Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 ForeachAction<Arg0objectSuperK, Arg0objectSuperV>

ForeachAction

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>, Named)

public void Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 ForeachAction<Arg0objectSuperK, Arg0objectSuperV>

ForeachAction

arg1 Named

Named

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

GroupByKey()

public KGroupedStream<K, V> GroupByKey()

Returns

KGroupedStream<K, V>

KGroupedStream

GroupByKey(Grouped<K, V>)

public KGroupedStream<K, V> GroupByKey(Grouped<K, V> arg0)

Parameters

arg0 Grouped<K, V>

Grouped

Returns

KGroupedStream<K, V>

KGroupedStream

GroupBy<KR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR>)

public KGroupedStream<KR, V> GroupBy<KR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR>

KeyValueMapper

Returns

KGroupedStream<KR, V>

KGroupedStream

Type Parameters

KR
Arg0objectSuperK

K

Arg0objectSuperV

V

GroupBy<KR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR>, Grouped<KR, V>)

public KGroupedStream<KR, V> GroupBy<KR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR> arg0, Grouped<KR, V> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KR>

KeyValueMapper

arg1 Grouped<KR, V>

Grouped

Returns

KGroupedStream<KR, V>

KGroupedStream

Type Parameters

KR
Arg0objectSuperK

K

Arg0objectSuperV

V

Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>)

public KStream<K, RV> Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoinerWithKey

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperK

K

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>, Named)

public KStream<K, RV> Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoinerWithKey

arg3 Named

Named

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperK

K

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

Join<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> Join<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> Join<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>)

public KStream<K, VR> Join<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoiner

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

Join<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>, Joined<K, V, VT>)

public KStream<K, VR> Join<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1, Joined<K, V, VT> arg2) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoiner

arg2 Joined<K, V, VT>

Joined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

Join<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> Join<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> Join<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>)

public KStream<K, VR> Join<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoinerWithKey

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

Join<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>, Joined<K, V, VT>)

public KStream<K, VR> Join<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1, Joined<K, V, VT> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 Joined<K, V, VT>

Joined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>)

public KStream<K, RV> Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV

Parameters

arg0 GlobalKTable<GK, GV>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoiner

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>, Named)

public KStream<K, RV> Join<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoiner

arg3 Named

Named

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>)

public KStream<K, RV> LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoinerWithKey

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperK

K

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>, Named)

public KStream<K, RV> LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoinerWithKey

arg3 Named

Named

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperK

K

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

LeftJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> LeftJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> LeftJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>)

public KStream<K, VR> LeftJoin<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoiner

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

LeftJoin<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>, Joined<K, V, VT>)

public KStream<K, VR> LeftJoin<VR, VT, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1, Joined<K, V, VT> arg2) where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoiner

arg2 Joined<K, V, VT>

Joined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

LeftJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> LeftJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> LeftJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>)

public KStream<K, VR> LeftJoin<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoinerWithKey

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

LeftJoin<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>, Joined<K, V, VT>)

public KStream<K, VR> LeftJoin<VR, VT, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>(KTable<K, VT> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR> arg1, Joined<K, V, VT> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVT : VT where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VT>

KTable

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVT, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 Joined<K, V, VT>

Joined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VT
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVT

VT

Arg1ExtendsVR

VR

LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>)

public KStream<K, RV> LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGK : GK where Arg2objectSuperV : V where Arg2objectSuperGV : GV where Arg2ExtendsRV : RV

Parameters

arg0 GlobalKTable<GK, GV>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoiner

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>, Named)

public KStream<K, RV> LeftJoin<RV, GK, GV, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK, Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>(GlobalKTable<GK, GV> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV> 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>

GlobalKTable

arg1 KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGK>

KeyValueMapper

arg2 ValueJoiner<Arg2objectSuperV, Arg2objectSuperGV, Arg2ExtendsRV>

ValueJoiner

arg3 Named

Named

Returns

KStream<K, RV>

KStream

Type Parameters

RV
GK
GV
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1ExtendsGK

GK

Arg2objectSuperV

V

Arg2objectSuperGV

GV

Arg2ExtendsRV

RV

MapValues<VR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR>)

public KStream<K, VR> MapValues<VR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR> arg0) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR>

ValueMapper

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR>, Named)

public KStream<K, VR> MapValues<VR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR>

ValueMapper

arg1 Named

Named

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>)

public KStream<K, VR> MapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>

ValueMapperWithKey

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>, Named)

public KStream<K, VR> MapValues<VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>

ValueMapperWithKey

arg1 Named

Named

Returns

KStream<K, VR>

KStream

Type Parameters

VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

Map<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_>)

public KStream<KR, VR> Map<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_ : KeyValue<Arg0ExtendsKR, Arg0ExtendsVR> where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_>

KeyValueMapper

Returns

KStream<KR, VR>

KStream

Type Parameters

KR
VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_

KeyValue<K, V>

Arg0ExtendsKR

KR

Arg0ExtendsVR

VR

Map<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_>, Named)

public KStream<KR, VR> Map<KR, VR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_, Arg0ExtendsKR, Arg0ExtendsVR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_ : KeyValue<Arg0ExtendsKR, Arg0ExtendsVR> where Arg0ExtendsKR : KR where Arg0ExtendsVR : VR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_>

KeyValueMapper

arg1 Named

Named

Returns

KStream<KR, VR>

KStream

Type Parameters

KR
VR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVR_

KeyValue<K, V>

Arg0ExtendsKR

KR

Arg0ExtendsVR

VR

Merge(KStream<K, V>)

public KStream<K, V> Merge(KStream<K, V> arg0)

Parameters

arg0 KStream<K, V>

KStream

Returns

KStream<K, V>

KStream

Merge(KStream<K, V>, Named)

public KStream<K, V> Merge(KStream<K, V> arg0, Named arg1)

Parameters

arg0 KStream<K, V>

KStream

arg1 Named

Named

Returns

KStream<K, V>

KStream

OuterJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> OuterJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> OuterJoin<VR, VO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows)

public KStream<K, VR> OuterJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>, JoinWindows, StreamJoined<K, V, VO>)

public KStream<K, VR> OuterJoin<VR, VO, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KStream<K, VO> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR> arg1, JoinWindows arg2, StreamJoined<K, V, VO> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KStream<K, VO>

KStream

arg1 ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined<K, V, VO>

StreamJoined

Returns

KStream<K, VR>

KStream

Type Parameters

VR
VO
Arg1objectSuperK

K

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>)

public KStream<K, V> Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 ForeachAction<Arg0objectSuperK, Arg0objectSuperV>

ForeachAction

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>, Named)

public KStream<K, V> Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 ForeachAction<Arg0objectSuperK, Arg0objectSuperV>

ForeachAction

arg1 Named

Named

Returns

KStream<K, V>

KStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Print(Printed<K, V>)

public void Print(Printed<K, V> arg0)

Parameters

arg0 Printed<K, V>

Printed

Repartition()

public KStream<K, V> Repartition()

Returns

KStream<K, V>

KStream

Repartition(Repartitioned<K, V>)

public KStream<K, V> Repartition(Repartitioned<K, V> arg0)

Parameters

arg0 Repartitioned<K, V>

Repartitioned

Returns

KStream<K, V>

KStream

SelectKey<KR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>)

public KStream<KR, V> SelectKey<KR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>

KeyValueMapper

Returns

KStream<KR, V>

KStream

Type Parameters

KR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsKR

KR

SelectKey<KR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>, Named)

public KStream<KR, V> SelectKey<KR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>

KeyValueMapper

arg1 Named

Named

Returns

KStream<KR, V>

KStream

Type Parameters

KR
Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsKR

KR

Split()

public BranchedKStream<K, V> Split()

Returns

BranchedKStream<K, V>

BranchedKStream

Split(Named)

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

Parameters

arg0 Named

Named

Returns

BranchedKStream<K, V>

BranchedKStream

To(String)

public void To(String arg0)

Parameters

arg0 String

String

To(String, Produced<K, V>)

public void To(String arg0, Produced<K, V> arg1)

Parameters

arg0 String

String

arg1 Produced<K, V>

Produced

To(TopicNameExtractor<K, V>)

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

Parameters

arg0 TopicNameExtractor<K, V>

TopicNameExtractor

To(TopicNameExtractor<K, V>, Produced<K, V>)

public void To(TopicNameExtractor<K, V> arg0, Produced<K, V> arg1)

Parameters

arg0 TopicNameExtractor<K, V>

TopicNameExtractor

arg1 Produced<K, V>

Produced

ToTable()

public KTable<K, V> ToTable()

Returns

KTable<K, V>

KTable

ToTable(Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

public KTable<K, V> ToTable(Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg0)

Parameters

arg0 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

KTable<K, V>

KTable

ToTable(Named)

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

Parameters

arg0 Named

Named

Returns

KTable<K, V>

KTable

ToTable(Named, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)

public KTable<K, V> ToTable(Named arg0, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg1)

Parameters

arg0 Named

Named

arg1 Materialized<K, V, KeyValueStore<Bytes, byte[]>>

Materialized

Returns

KTable<K, V>

KTable

Operators

implicit operator KStream(KStream<K, V>)

Converter from KStream<K, V> to KStream

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

Parameters

t KStream<K, V>

Returns

KStream