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/4.1.0/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/4.1.0/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/4.1.0/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)

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>)

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/4.1.0/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/4.1.0/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/4.1.0/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>)

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/4.1.0/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/4.1.0/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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/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, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>: KTable<K, V, TJVMK, TJVMV>
arg1 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>)

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>, Materialized<K, VR, TJVMK, TJVMVR>)

public KTable<K, VR, TJVMK, TJVMVR> Join<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

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>)

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>)

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>)

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/4.1.0/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/4.1.0/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/4.1.0/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/4.1.0/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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/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, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO> arg1, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR> arg2)

Parameters

arg0 KTable<KO, VO, TJVMKO, TJVMVO>: KTable<K, V, TJVMK, TJVMV>
arg1 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>)

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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>, BiFunction<K, V, KO, TJVMK, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>, TableJoined<K, KO, TJVMK, TJVMKO>, Materialized<K, VR, TJVMK, TJVMVR>)

public KTable<K, VR, TJVMK, TJVMVR> LeftJoin<VR, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO> arg0, BiFunction<K, V, KO, TJVMK, 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 BiFunction<K, V, KO, TJVMK, 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, KO, VO, TJVMVR, TJVMKO, TJVMVO>(KTable<KO, VO, TJVMKO, TJVMVO>, Function<V, KO, TJVMV, TJVMKO>, ValueJoiner<V, VO, VR, TJVMV, TJVMVO, TJVMVR>)

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>)

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>)

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>)

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>)

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/4.1.0/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/4.1.0/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/4.1.0/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/4.1.0/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/4.1.0/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)

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>)

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/4.1.0/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>)

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)

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>)

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/4.1.0/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>)

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)

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>)

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/4.1.0/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/4.1.0/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/4.1.0/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/4.1.0/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/4.1.0/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>

Table of Contents

Class KTable<K, V, TJVMK, TJVMV>

Type Parameters

Properties

QueryableStoreName

Property Value

Methods

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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

Parameters

Returns

Type Parameters

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>)

Parameters

Returns

Type Parameters

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>)

Parameters

Returns

Type Parameters

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>)

Parameters

Returns

Type Parameters

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