Class KStream<K, V>
public class KStream<K, V> : JVMBridgeBase<KStream<K, V>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IKStream<K, V>
Type Parameters
K
V
- Inheritance
-
JVMBridgeBase<KStream<K, V>>KStream<K, V>
- Implements
-
IKStream<K, V>
- Inherited Members
-
JVMBridgeBase<KStream<K, V>>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<KStream<K, V>>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<KStream<K, V>>.SExecuteWithSignatureArray<TArrayType>(string, string, params object[])
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(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream(IJVMBridgeBaseInitializer initializer)
Parameters
initializer
IJVMBridgeBaseInitializer
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
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }
Property Value
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }
Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }
Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }
Property Value
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
Returns
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
Returns
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
Returns
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
Returns
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
FlatMapValues<VOut, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>)
public KStream<K, VOut> FlatMapValues<VOut, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_> arg0) where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_ : Iterable<Arg0ExtendsVOut> where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>
Returns
Type Parameters
VOut
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_
Arg0ExtendsVOut
VOut
FlatMapValues<VOut, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>, Named)
public KStream<K, VOut> FlatMapValues<VOut, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_ : Iterable<Arg0ExtendsVOut> where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>arg1
Named
Returns
Type Parameters
VOut
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_
Arg0ExtendsVOut
VOut
FlatMapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>)
public KStream<K, VOut> FlatMapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_ : Iterable<Arg0ExtendsVOut> where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_
Arg0ExtendsVOut
VOut
FlatMapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>, Named)
public KStream<K, VOut> FlatMapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_ : Iterable<Arg0ExtendsVOut> where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>arg1
Named
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_
Arg0ExtendsVOut
VOut
FlatMap<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__>)
public KStream<KOut, VOut> FlatMap<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__ : Iterable<Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_> where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_ : KeyValue<Arg0ExtendsKOut, Arg0ExtendsVOut> where Arg0ExtendsKOut : KOut where Arg0ExtendsVOut : VOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__>
Returns
Type Parameters
KOut
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__
Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_
Arg0ExtendsKOut
KOut
Arg0ExtendsVOut
VOut
FlatMap<KR, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_, Arg0ExtendsKR, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__>, Named)
public KStream<KR, VOut> FlatMap<KR, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_, Arg0ExtendsKR, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__ : Iterable<Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_> where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_ : KeyValue<Arg0ExtendsKR, Arg0ExtendsVOut> where Arg0ExtendsKR : KR where Arg0ExtendsVOut : VOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__>arg1
Named
Returns
Type Parameters
KR
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__
Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_
Arg0ExtendsKR
KR
Arg0ExtendsVOut
VOut
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>
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>arg1
Named
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
GroupByKey()
public KGroupedStream<K, V> GroupByKey()
Returns
- KGroupedStream<K, V>
GroupByKey(Grouped<K, V>)
public KGroupedStream<K, V> GroupByKey(Grouped<K, V> arg0)
Parameters
Returns
- KGroupedStream<K, V>
GroupBy<KOut, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>)
public KGroupedStream<KOut, V> GroupBy<KOut, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>
Returns
- KGroupedStream<KOut, V>
Type Parameters
KOut
Arg0objectSuperK
K
Arg0objectSuperV
V
GroupBy<KOut, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>, Grouped<KOut, V>)
public KGroupedStream<KOut, V> GroupBy<KOut, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut> arg0, Grouped<KOut, V> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>arg1
Grouped<KOut, V>
Returns
- KGroupedStream<KOut, V>
Type Parameters
KOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>)
public KStream<K, VOut> Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>, Named)
public KStream<K, VOut> Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3
Named
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
Join<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> Join<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
Join<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> Join<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
Join<VOut, TableValue, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>)
public KStream<K, VOut> Join<VOut, TableValue, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut> arg1) where Arg1objectSuperV : V where Arg1objectSuperTableValue : TableValue where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, TableValue>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>
Returns
Type Parameters
VOut
TableValue
Arg1objectSuperV
V
Arg1objectSuperTableValue
TableValue
Arg1ExtendsVOut
VOut
Join<VOut, TableValue, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>, Joined<K, V, TableValue>)
public KStream<K, VOut> Join<VOut, TableValue, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut> arg1, Joined<K, V, TableValue> arg2) where Arg1objectSuperV : V where Arg1objectSuperTableValue : TableValue where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, TableValue>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>arg2
Joined<K, V, TableValue>
Returns
Type Parameters
VOut
TableValue
Arg1objectSuperV
V
Arg1objectSuperTableValue
TableValue
Arg1ExtendsVOut
VOut
Join<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> Join<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
Join<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> Join<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
Join<VOut, TableValue, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>)
public KStream<K, VOut> Join<VOut, TableValue, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperTableValue : TableValue where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, TableValue>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>
Returns
Type Parameters
VOut
TableValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperTableValue
TableValue
Arg1ExtendsVOut
VOut
Join<VOut, TableValue, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>, Joined<K, V, TableValue>)
public KStream<K, VOut> Join<VOut, TableValue, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>(KTable<K, TableValue> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut> arg1, Joined<K, V, TableValue> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperTableValue : TableValue where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, TableValue>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>arg2
Joined<K, V, TableValue>
Returns
Type Parameters
VOut
TableValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperTableValue
TableValue
Arg1ExtendsVOut
VOut
Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>)
public KStream<K, VOut> Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>, Named)
public KStream<K, VOut> Join<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3
Named
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>)
public KStream<K, VOut> LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>, Named)
public KStream<K, VOut> LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperK : K where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3
Named
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperK
K
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
LeftJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> LeftJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> LeftJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VTable, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>)
public KStream<K, VOut> LeftJoin<VOut, VTable, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut> arg1) where Arg1objectSuperV : V where Arg1objectSuperVTable : VTable where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, VTable>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>
Returns
Type Parameters
VOut
VTable
Arg1objectSuperV
V
Arg1objectSuperVTable
VTable
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VTable, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>, Joined<K, V, VTable>)
public KStream<K, VOut> LeftJoin<VOut, VTable, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut> arg1, Joined<K, V, VTable> arg2) where Arg1objectSuperV : V where Arg1objectSuperVTable : VTable where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, VTable>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>arg2
Joined<K, V, VTable>
Returns
Type Parameters
VOut
VTable
Arg1objectSuperV
V
Arg1objectSuperVTable
VTable
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> LeftJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> LeftJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VTable, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>)
public KStream<K, VOut> LeftJoin<VOut, VTable, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut> arg1) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVTable : VTable where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, VTable>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>
Returns
Type Parameters
VOut
VTable
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVTable
VTable
Arg1ExtendsVOut
VOut
LeftJoin<VOut, VTable, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>, Joined<K, V, VTable>)
public KStream<K, VOut> LeftJoin<VOut, VTable, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>(KTable<K, VTable> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut> arg1, Joined<K, V, VTable> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVTable : VTable where Arg1ExtendsVOut : VOut
Parameters
arg0
KTable<K, VTable>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>arg2
Joined<K, V, VTable>
Returns
Type Parameters
VOut
VTable
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVTable
VTable
Arg1ExtendsVOut
VOut
LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>)
public KStream<K, VOut> LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>, Named)
public KStream<K, VOut> LeftJoin<VOut, GlobalKey, GlobalValue, Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>(GlobalKTable<GlobalKey, GlobalValue> arg0, KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey> arg1, ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1ExtendsGlobalKey : GlobalKey where Arg2objectSuperV : V where Arg2objectSuperGlobalValue : GlobalValue where Arg2ExtendsVOut : VOut
Parameters
arg0
GlobalKTable<GlobalKey, GlobalValue>arg1
KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2
ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3
Named
Returns
Type Parameters
VOut
GlobalKey
GlobalValue
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1ExtendsGlobalKey
GlobalKey
Arg2objectSuperV
V
Arg2objectSuperGlobalValue
GlobalValue
Arg2ExtendsVOut
VOut
MapValues<VOut, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>)
public KStream<K, VOut> MapValues<VOut, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut> arg0) where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>
Returns
Type Parameters
VOut
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
MapValues<VOut, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>, Named)
public KStream<K, VOut> MapValues<VOut, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>arg1
Named
Returns
Type Parameters
VOut
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
MapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>)
public KStream<K, VOut> MapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
MapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>, Named)
public KStream<K, VOut> MapValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1
Named
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
Map<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>)
public KStream<KOut, VOut> Map<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_ : KeyValue<Arg0ExtendsKOut, Arg0ExtendsVOut> where Arg0ExtendsKOut : KOut where Arg0ExtendsVOut : VOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>
Returns
Type Parameters
KOut
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_
Arg0ExtendsKOut
KOut
Arg0ExtendsVOut
VOut
Map<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>, Named)
public KStream<KOut, VOut> Map<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_, Arg0ExtendsKOut, Arg0ExtendsVOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_ : KeyValue<Arg0ExtendsKOut, Arg0ExtendsVOut> where Arg0ExtendsKOut : KOut where Arg0ExtendsVOut : VOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>arg1
Named
Returns
Type Parameters
KOut
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_
Arg0ExtendsKOut
KOut
Arg0ExtendsVOut
VOut
Merge(KStream<K, V>)
public KStream<K, V> Merge(KStream<K, V> arg0)
Parameters
Returns
Merge(KStream<K, V>, Named)
public KStream<K, V> Merge(KStream<K, V> arg0, Named arg1)
Parameters
Returns
OuterJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> OuterJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
OuterJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> OuterJoin<VOut, VRight, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
OuterJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows)
public KStream<K, VOut> OuterJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindows
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
OuterJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight>, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>, JoinWindows, StreamJoined<K, V, VRight>)
public KStream<K, VOut> OuterJoin<VOut, VRight, Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>(KStream<K, VRight> arg0, ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut> arg1, JoinWindows arg2, StreamJoined<K, V, VRight> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg1objectSuperVRight : VRight where Arg1ExtendsVOut : VOut
Parameters
arg0
KStream<K, VRight>arg1
ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2
JoinWindowsarg3
StreamJoined<K, V, VRight>
Returns
Type Parameters
VOut
VRight
Arg1objectSuperK
K
Arg1objectSuperV
V
Arg1objectSuperVRight
VRight
Arg1ExtendsVOut
VOut
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>
Returns
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>arg1
Named
Returns
Type Parameters
Arg0objectSuperK
K
Arg0objectSuperV
V
Print(Printed<K, V>)
public void Print(Printed<K, V> arg0)
Parameters
ProcessValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>, params String[])
public KStream<K, VOut> ProcessValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut> arg0, params String[] arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1
String[]
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
ProcessValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>, Named, params String[])
public KStream<K, VOut> ProcessValues<VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>(FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut> arg0, Named arg1, params String[] arg2) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVOut : VOut
Parameters
arg0
FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1
Namedarg2
String[]
Returns
Type Parameters
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsVOut
VOut
Process<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>(ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>, params String[])
public KStream<KOut, VOut> Process<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>(ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut> arg0, params String[] arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKOut : KOut where Arg0ExtendsVOut : VOut
Parameters
arg0
ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>arg1
String[]
Returns
Type Parameters
KOut
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKOut
KOut
Arg0ExtendsVOut
VOut
Process<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>(ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>, Named, params String[])
public KStream<KOut, VOut> Process<KOut, VOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>(ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut> arg0, Named arg1, params String[] arg2) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKOut : KOut where Arg0ExtendsVOut : VOut
Parameters
arg0
ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>arg1
Namedarg2
String[]
Returns
Type Parameters
KOut
VOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKOut
KOut
Arg0ExtendsVOut
VOut
Repartition()
public KStream<K, V> Repartition()
Returns
Repartition(Repartitioned<K, V>)
public KStream<K, V> Repartition(Repartitioned<K, V> arg0)
Parameters
arg0
Repartitioned<K, V>
Returns
SelectKey<KOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>)
public KStream<KOut, V> SelectKey<KOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKOut : KOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>
Returns
Type Parameters
KOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKOut
KOut
SelectKey<KOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>, Named)
public KStream<KOut, V> SelectKey<KOut, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKOut : KOut
Parameters
arg0
KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>arg1
Named
Returns
Type Parameters
KOut
Arg0objectSuperK
K
Arg0objectSuperV
V
Arg0ExtendsKOut
KOut
Split()
public BranchedKStream<K, V> Split()
Returns
Split(Named)
public BranchedKStream<K, V> Split(Named arg0)
Parameters
Returns
To(String)
public void To(String arg0)
Parameters
To(String, Produced<K, V>)
public void To(String arg0, Produced<K, V> arg1)
Parameters
To(TopicNameExtractor<K, V>)
public void To(TopicNameExtractor<K, V> arg0)
Parameters
arg0
TopicNameExtractor<K, V>
To(TopicNameExtractor<K, V>, Produced<K, V>)
public void To(TopicNameExtractor<K, V> arg0, Produced<K, V> arg1)
Parameters
arg0
TopicNameExtractor<K, V>arg1
Produced<K, V>
ToTable()
public KTable<K, V> ToTable()
Returns
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[]>>
Returns
ToTable(Named)
public KTable<K, V> ToTable(Named arg0)
Parameters
Returns
ToTable(Named, Materialized<K, V, KeyValueStore<Bytes, byte[]>>)
public KTable<K, V> ToTable(Named arg0, Materialized<K, V, KeyValueStore<Bytes, byte[]>> arg1)
Parameters
arg0
Namedarg1
Materialized<K, V, KeyValueStore<Bytes, byte[]>>
Returns
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>