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
KV
- 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
initializerIJVMBridgeBaseInitializer
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
argsobject[]
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
Arg0objectSuperKKArg0objectSuperVV
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
Arg0objectSuperKKArg0objectSuperVV
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
Arg0objectSuperKKArg0objectSuperVV
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
Arg0objectSuperKKArg0objectSuperVV
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
arg0ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>
Returns
Type Parameters
VOutArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_Arg0ExtendsVOutVOut
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
arg0ValueMapper<Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>arg1Named
Returns
Type Parameters
VOutArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_Arg0ExtendsVOutVOut
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
arg0ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_Arg0ExtendsVOutVOut
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
arg0ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_>arg1Named
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsVOut_Arg0ExtendsVOutVOut
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__>
Returns
Type Parameters
KOutVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut__Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_Arg0ExtendsKOutKOutArg0ExtendsVOutVOut
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__>arg1Named
Returns
Type Parameters
KRVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsJava_Lang_Iterable_Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut__Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKR_Arg0ExtendsVOut_Arg0ExtendsKRKRArg0ExtendsVOutVOut
Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>)
public void Foreach<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0ForeachAction<Arg0objectSuperK, Arg0objectSuperV>
Type Parameters
Arg0objectSuperKKArg0objectSuperVV
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
arg0ForeachAction<Arg0objectSuperK, Arg0objectSuperV>arg1Named
Type Parameters
Arg0objectSuperKKArg0objectSuperVV
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>
Returns
- KGroupedStream<KOut, V>
Type Parameters
KOutArg0objectSuperKKArg0objectSuperVV
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, KOut>arg1Grouped<KOut, V>
Returns
- KGroupedStream<KOut, V>
Type Parameters
KOutArg0objectSuperKKArg0objectSuperVV
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperKKArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3Named
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperKKArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KTable<K, TableValue>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>
Returns
Type Parameters
VOutTableValueArg1objectSuperVVArg1objectSuperTableValueTableValueArg1ExtendsVOutVOut
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
arg0KTable<K, TableValue>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>arg2Joined<K, V, TableValue>
Returns
Type Parameters
VOutTableValueArg1objectSuperVVArg1objectSuperTableValueTableValueArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KTable<K, TableValue>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>
Returns
Type Parameters
VOutTableValueArg1objectSuperKKArg1objectSuperVVArg1objectSuperTableValueTableValueArg1ExtendsVOutVOut
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
arg0KTable<K, TableValue>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperTableValue, Arg1ExtendsVOut>arg2Joined<K, V, TableValue>
Returns
Type Parameters
VOutTableValueArg1objectSuperKKArg1objectSuperVVArg1objectSuperTableValueTableValueArg1ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3Named
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperKKArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoinerWithKey<Arg2objectSuperK, Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3Named
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperKKArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KTable<K, VTable>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>
Returns
Type Parameters
VOutVTableArg1objectSuperVVArg1objectSuperVTableVTableArg1ExtendsVOutVOut
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
arg0KTable<K, VTable>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>arg2Joined<K, V, VTable>
Returns
Type Parameters
VOutVTableArg1objectSuperVVArg1objectSuperVTableVTableArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KTable<K, VTable>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>
Returns
Type Parameters
VOutVTableArg1objectSuperKKArg1objectSuperVVArg1objectSuperVTableVTableArg1ExtendsVOutVOut
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
arg0KTable<K, VTable>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVTable, Arg1ExtendsVOut>arg2Joined<K, V, VTable>
Returns
Type Parameters
VOutVTableArg1objectSuperKKArg1objectSuperVVArg1objectSuperVTableVTableArg1ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0GlobalKTable<GlobalKey, GlobalValue>arg1KeyValueMapper<Arg1objectSuperK, Arg1objectSuperV, Arg1ExtendsGlobalKey>arg2ValueJoiner<Arg2objectSuperV, Arg2objectSuperGlobalValue, Arg2ExtendsVOut>arg3Named
Returns
Type Parameters
VOutGlobalKeyGlobalValueArg1objectSuperKKArg1objectSuperVVArg1ExtendsGlobalKeyGlobalKeyArg2objectSuperVVArg2objectSuperGlobalValueGlobalValueArg2ExtendsVOutVOut
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
arg0ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>
Returns
Type Parameters
VOutArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0ValueMapper<Arg0objectSuperV, Arg0ExtendsVOut>arg1Named
Returns
Type Parameters
VOutArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1Named
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>
Returns
Type Parameters
KOutVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_Arg0ExtendsKOutKOutArg0ExtendsVOutVOut
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_>arg1Named
Returns
Type Parameters
KOutVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsOrg_Apache_Kafka_Streams_KeyValue_Arg0ExtendsKOut_Arg0ExtendsVOut_Arg0ExtendsKOutKOutArg0ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoiner<Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindows
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
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
arg0KStream<K, VRight>arg1ValueJoinerWithKey<Arg1objectSuperK, Arg1objectSuperV, Arg1objectSuperVRight, Arg1ExtendsVOut>arg2JoinWindowsarg3StreamJoined<K, V, VRight>
Returns
Type Parameters
VOutVRightArg1objectSuperKKArg1objectSuperVVArg1objectSuperVRightVRightArg1ExtendsVOutVOut
Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV>)
public KStream<K, V> Peek<Arg0objectSuperK, Arg0objectSuperV>(ForeachAction<Arg0objectSuperK, Arg0objectSuperV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V
Parameters
arg0ForeachAction<Arg0objectSuperK, Arg0objectSuperV>
Returns
Type Parameters
Arg0objectSuperKKArg0objectSuperVV
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
arg0ForeachAction<Arg0objectSuperK, Arg0objectSuperV>arg1Named
Returns
Type Parameters
Arg0objectSuperKKArg0objectSuperVV
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
arg0FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1String[]
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0FixedKeyProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVOut>arg1Namedarg2String[]
Returns
Type Parameters
VOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsVOutVOut
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
arg0ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>arg1String[]
Returns
Type Parameters
KOutVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsKOutKOutArg0ExtendsVOutVOut
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
arg0ProcessorSupplier<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut, Arg0ExtendsVOut>arg1Namedarg2String[]
Returns
Type Parameters
KOutVOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsKOutKOutArg0ExtendsVOutVOut
Repartition()
public KStream<K, V> Repartition()
Returns
Repartition(Repartitioned<K, V>)
public KStream<K, V> Repartition(Repartitioned<K, V> arg0)
Parameters
arg0Repartitioned<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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>
Returns
Type Parameters
KOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsKOutKOut
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
arg0KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKOut>arg1Named
Returns
Type Parameters
KOutArg0objectSuperKKArg0objectSuperVVArg0ExtendsKOutKOut
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
arg0TopicNameExtractor<K, V>
To(TopicNameExtractor<K, V>, Produced<K, V>)
public void To(TopicNameExtractor<K, V> arg0, Produced<K, V> arg1)
Parameters
arg0TopicNameExtractor<K, V>arg1Produced<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
arg0Materialized<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
arg0Namedarg1Materialized<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
tKStream<K, V>