Class KTable<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of KTable<K, V>

public class KTable<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

KTable<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

QueryableStoreName

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#queryableStoreName--

public string QueryableStoreName { get; }

Property Value

string

string

Methods

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filterNot-org.apache.kafka.streams.kstream.Predicate-

public KTable<K, V, TJVMK, TJVMV> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filterNot-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, V, TJVMK, TJVMV> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Materialized<K, V, TJVMK, TJVMV> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filterNot-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Named-

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

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filterNot-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, V, TJVMK, TJVMV> FilterNot<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1, Materialized<K, V, TJVMK, TJVMV> arg2) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filter-org.apache.kafka.streams.kstream.Predicate-

public KTable<K, V, TJVMK, TJVMV> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filter-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, V, TJVMK, TJVMV> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Materialized<K, V, TJVMK, TJVMV> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filter-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Named-

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

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#filter-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, V, TJVMK, TJVMV> Filter<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Named arg1, Materialized<K, V, TJVMK, TJVMV> arg2) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Named

Named

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

GroupBy<KR, TJVMKR, VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#groupBy-org.apache.kafka.streams.kstream.KeyValueMapper-

public KGroupedTable<KR, VR, TJVMKR, TJVMVR> GroupBy<KR, TJVMKR, VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>>

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

Returns

KGroupedTable<KR, VR, TJVMKR, TJVMVR>

KGroupedTable<K, V, TJVMK, TJVMV>

Type Parameters

KR

TJVMKR

The JVM type of KR

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

GroupBy<KR, TJVMKR, VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>>, Grouped<KR, VR, TJVMKR, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#groupBy-org.apache.kafka.streams.kstream.KeyValueMapper-org.apache.kafka.streams.kstream.Grouped-

public KGroupedTable<KR, VR, TJVMKR, TJVMVR> GroupBy<KR, TJVMKR, VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>> arg0, Grouped<KR, VR, TJVMKR, TJVMVR> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, VR, TJVMK, TJVMV, KeyValue<TJVMKR, TJVMVR>>

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

arg1 Grouped<KR, VR, TJVMKR, TJVMVR>

Grouped<K, V, TJVMK, TJVMV>

Returns

KGroupedTable<KR, VR, TJVMKR, TJVMVR>

KGroupedTable<K, V, TJVMK, TJVMV>

Type Parameters

KR

TJVMKR

The JVM type of KR

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.TableJoined-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, TableJoined<K, KO, TJVMK, TJVMKO> arg3)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 TableJoined<K, KO, TJVMK, TJVMKO>

TableJoined<K, KO, TJVMK, TJVMKO>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.TableJoined-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, TableJoined<K, KO, TJVMK, TJVMKO> arg3, Materialized<K, VR, TJVMK, TJVMVR> arg4)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 TableJoined<K, KO, TJVMK, TJVMKO>

TableJoined<K, KO, TJVMK, TJVMKO>

arg4 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Materialized<K, VR, TJVMK, TJVMVR> arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

ValueJoiner<V1, V2, VR>

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.TableJoined-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, TableJoined<K, KO, TJVMK, TJVMKO> arg3)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 TableJoined<K, KO, TJVMK, TJVMKO>

TableJoined<K, KO, TJVMK, TJVMKO>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.TableJoined-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, Function<V, KO, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2, TableJoined<K, KO, TJVMK, TJVMKO> arg3, Materialized<K, VR, TJVMK, TJVMVR> arg4)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

arg1 Function<V, KO, TJVMV, TJVMKO>

Function

arg2 ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>

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

arg3 TableJoined<K, KO, TJVMK, TJVMKO>

TableJoined<K, KO, TJVMK, TJVMKO>

arg4 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

KO

VO

TJVMVR

The JVM type of VR

TJVMKO

The JVM type of KO

TJVMVO

The JVM type of VO

LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Materialized<K, VR, TJVMK, TJVMVR> arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

LeftJoin<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#leftJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, TJVMVR, VO, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

VO

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapper-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>

ValueMapper<V, VR, TJVMV, TJVMVR>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapper-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0, Materialized<K, VR, TJVMK, TJVMVR> arg1) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>

ValueMapper<V, VR, TJVMV, TJVMVR>

arg1 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperV

V

Arg0ExtendsVR

VR

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapper-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>

ValueMapper<V, VR, TJVMV, TJVMVR>

arg1 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapper-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR> arg0, Named arg1, Materialized<K, VR, TJVMK, TJVMVR> arg2) where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapper<Arg0objectSuperV, Arg0ExtendsVR, TJVMV, TJVMVR>

ValueMapper<V, VR, TJVMV, TJVMVR>

arg1 Named

Named

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapperWithKey-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapperWithKey-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0, Materialized<K, VR, TJVMK, TJVMVR> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>

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

arg1 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapperWithKey-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>

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

arg1 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#mapValues-org.apache.kafka.streams.kstream.ValueMapperWithKey-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> MapValues<VR, TJVMVR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR>(ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR> arg0, Named arg1, Materialized<K, VR, TJVMK, TJVMVR> arg2) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsVR : VR

Parameters

arg0 ValueMapperWithKey<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsVR, TJVMK, TJVMV, TJVMVR>

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

arg1 Named

Named

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsVR

VR

OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#outerJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-

public KTable<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#outerJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Materialized<K, VR, TJVMK, TJVMVR> arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#outerJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO>, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#outerJoin-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VR, TJVMK, TJVMVR> OuterJoin<VR, VO, TJVMVR, TJVMVO, Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR>(KTable<K, VO, TJVMK, TJVMVO> arg0, ValueJoiner<Arg1objectSuperV, Arg1objectSuperVO, Arg1ExtendsVR, TJVMV, TJVMVO, TJVMVR> arg1, Named arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperV : V where Arg1objectSuperVO : VO where Arg1ExtendsVR : VR

Parameters

arg0 KTable<K, VO, TJVMK, TJVMVO>

KTable<K, V, TJVMK, TJVMV>

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

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

arg2 Named

Named

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

VO

TJVMVR

The JVM type of VR

TJVMVO

The JVM type of VO

Arg1objectSuperV

V

Arg1objectSuperVO

VO

Arg1ExtendsVR

VR

Suppress<Arg0objectSuperK>(Suppressed<Arg0objectSuperK, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#suppress-org.apache.kafka.streams.kstream.Suppressed-

public KTable<K, V, TJVMK, TJVMV> Suppress<Arg0objectSuperK>(Suppressed<Arg0objectSuperK, TJVMK> arg0) where Arg0objectSuperK : K

Parameters

arg0 Suppressed<Arg0objectSuperK, TJVMK>

Suppressed<K, TJVMK>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg0objectSuperK

K

ToStream()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#toStream--

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

Returns

KStream<K, V, TJVMK, TJVMV>

KStream<K, V, TJVMK, TJVMV>

ToStream(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#toStream-org.apache.kafka.streams.kstream.Named-

public KStream<K, V, TJVMK, TJVMV> ToStream(Named arg0)

Parameters

arg0 Named

Named

Returns

KStream<K, V, TJVMK, TJVMV>

KStream<K, V, TJVMK, TJVMV>

ToStream<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#toStream-org.apache.kafka.streams.kstream.KeyValueMapper-

public KStream<KR, V, TJVMKR, TJVMV> ToStream<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>

KeyValueMapper

Returns

KStream<KR, V, TJVMKR, TJVMV>

KStream<K, V, TJVMK, TJVMV>

Type Parameters

KR

TJVMKR

The JVM type of KR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsKR

KR

ToStream<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/KTable.html#toStream-org.apache.kafka.streams.kstream.KeyValueMapper-org.apache.kafka.streams.kstream.Named-

public KStream<KR, V, TJVMKR, TJVMV> ToStream<KR, TJVMKR, Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR>(KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR> arg0, Named arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V where Arg0ExtendsKR : KR

Parameters

arg0 KeyValueMapper<Arg0objectSuperK, Arg0objectSuperV, Arg0ExtendsKR, TJVMK, TJVMV, TJVMKR>

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

arg1 Named

Named

Returns

KStream<KR, V, TJVMKR, TJVMV>

KStream<K, V, TJVMK, TJVMV>

Type Parameters

KR

TJVMKR

The JVM type of KR

Arg0objectSuperK

K

Arg0objectSuperV

V

Arg0ExtendsKR

KR

Operators

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

Converter from KTable<K, V, TJVMK, TJVMV> to KTable<K, V>

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

Parameters

t KTable<K, V, TJVMK, TJVMV>

Returns

KTable<TJVMK, TJVMV>