Package com.bakdata.kafka.streams.kstream

Interface KTableX<K,V>

Type Parameters:

K - type of keys

V - type of values

All Superinterfaces:

org.apache.kafka.streams.kstream.KTable<K,V>

public interface KTableX<K,V>
extends org.apache.kafka.streams.kstream.KTable<K,V>

Extends the KTable interface by adding methods to simplify Serde configuration, error handling, and topic access

Method Summary

Modifier and Type	Method	Description
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<KR, VR> KGroupedTableX<KR,VR>	groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector)
<KR, VR> KGroupedTableX<KR,VR>	groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector, GroupedX<KR,VR> grouped)
<KR, VR> KGroupedTableX<KR,VR>	groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector, org.apache.kafka.streams.kstream.Grouped<KR,VR> grouped)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	join(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, BiFunction<K,V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR, KO, VO> KTableX<K,VR>	leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other, Function<V,KO> foreignKeyExtractor, org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner, org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VR> KTableX<K,VR>	mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
<VO, VR> KTableX<K,VR>	outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
KTableX<K,V>	suppress(org.apache.kafka.streams.kstream.Suppressed<? super K> suppressed)
KStreamX<K,V>	toStream()
<KR> KStreamX<KR,V>	toStream(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper)
<KR> KStreamX<KR,V>	toStream(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper, org.apache.kafka.streams.kstream.Named named)
KStreamX<K,V>	toStream(org.apache.kafka.streams.kstream.Named named)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized, String... stateStoreNames)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, String... stateStoreNames)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized, String... stateStoreNames)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
<VR> KTableX<K,VR>	transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

Methods inherited from interface org.apache.kafka.streams.kstream.KTable

queryableStoreName

Method Details

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)

Specified by:

filter in interface org.apache.kafka.streams.kstream.KTable<K,V>

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

filter in interface org.apache.kafka.streams.kstream.KTable<K,V>

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

filter in interface org.apache.kafka.streams.kstream.KTable<K,V>

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• filter(Predicate, Materialized)

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

filter in interface org.apache.kafka.streams.kstream.KTable<K,V>

filter

KTableX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• filter(Predicate, Named, Materialized)

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)

Specified by:

filterNot in interface org.apache.kafka.streams.kstream.KTable<K,V>

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

filterNot in interface org.apache.kafka.streams.kstream.KTable<K,V>

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

filterNot in interface org.apache.kafka.streams.kstream.KTable<K,V>

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• filterNot(Predicate, Materialized)

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

filterNot in interface org.apache.kafka.streams.kstream.KTable<K,V>

filterNot

KTableX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• filterNot(Predicate, Named, Materialized)

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• mapValues(ValueMapper, Materialized)

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• mapValues(ValueMapper, Named, Materialized)

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• mapValues(ValueMapperWithKey, Materialized)

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

mapValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

mapValues

<VR> KTableX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• mapValues(ValueMapperWithKey, Named, Materialized)

toStream

KStreamX<K,V> toStream()

Specified by:

toStream in interface org.apache.kafka.streams.kstream.KTable<K,V>

toStream

KStreamX<K,V> toStream(org.apache.kafka.streams.kstream.Named named)

Specified by:

toStream in interface org.apache.kafka.streams.kstream.KTable<K,V>

toStream

<KR> KStreamX<KR,V> toStream(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper)

Specified by:

toStream in interface org.apache.kafka.streams.kstream.KTable<K,V>

toStream

<KR> KStreamX<KR,V> toStream(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

toStream in interface org.apache.kafka.streams.kstream.KTable<K,V>

suppress

KTableX<K,V> suppress(org.apache.kafka.streams.kstream.Suppressed<? super K> suppressed)

Specified by:

suppress in interface org.apache.kafka.streams.kstream.KTable<K,V>

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 String... stateStoreNames)

Specified by:

transformValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 org.apache.kafka.streams.kstream.Named named,
 String... stateStoreNames)

Specified by:

transformValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized,
 String... stateStoreNames)

Specified by:

transformValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized,
 String... stateStoreNames)

See Also:

• transformValues(ValueTransformerWithKeySupplier, Materialized, String...)

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized,
 org.apache.kafka.streams.kstream.Named named,
 String... stateStoreNames)

Specified by:

transformValues in interface org.apache.kafka.streams.kstream.KTable<K,V>

transformValues

<VR> KTableX<K,VR> transformValues(org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<? super K,? super V,? extends VR> transformerSupplier,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized,
 org.apache.kafka.streams.kstream.Named named,
 String... stateStoreNames)

See Also:

• transformValues(ValueTransformerWithKeySupplier, Materialized, Named, String...)

groupBy

<KR,
VR> KGroupedTableX<KR,VR> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector)

Specified by:

groupBy in interface org.apache.kafka.streams.kstream.KTable<K,V>

groupBy

<KR,
VR> KGroupedTableX<KR,VR> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector,
 org.apache.kafka.streams.kstream.Grouped<KR,VR> grouped)

Specified by:

groupBy in interface org.apache.kafka.streams.kstream.KTable<K,V>

groupBy

<KR,
VR> KGroupedTableX<KR,VR> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,org.apache.kafka.streams.KeyValue<KR,VR>> selector,
 GroupedX<KR,VR> grouped)

See Also:

• groupBy(KeyValueMapper, Grouped)

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, ValueJoiner, Materialized)

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VO,
VR> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, ValueJoiner, Named, Materialized)

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, ValueJoiner, Materialized)

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VO,
VR> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, ValueJoiner, Named, Materialized)

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner)

Specified by:

outerJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named)

Specified by:

outerJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

outerJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• outerJoin(KTable, ValueJoiner, Materialized)

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

outerJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

outerJoin

<VO,
VR> KTableX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KTable<K,VO> other,
 org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner,
 org.apache.kafka.streams.kstream.Named named,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• outerJoin(KTable, ValueJoiner, Named, Materialized)

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, Function, ValueJoiner, Materialized)

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, Function, ValueJoiner, TableJoined, Materialized)

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, Function, ValueJoiner, Materialized)

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 Function<V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, Function, ValueJoiner, TableJoined, Materialized)

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, BiFunction, ValueJoiner, Materialized)

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

join in interface org.apache.kafka.streams.kstream.KTable<K,V>

join

<VR,
KO,
VO> KTableX<K,VR> join(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• join(KTable, BiFunction, ValueJoiner, TableJoined, Materialized)

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, BiFunction, ValueJoiner, Materialized)

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Specified by:

leftJoin in interface org.apache.kafka.streams.kstream.KTable<K,V>

leftJoin

<VR,
KO,
VO> KTableX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<KO,VO> other,
 BiFunction<K,V,KO> foreignKeyExtractor,
 org.apache.kafka.streams.kstream.ValueJoiner<V,VO,VR> joiner,
 org.apache.kafka.streams.kstream.TableJoined<K,KO> tableJoined,
 MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

See Also:

• leftJoin(KTable, BiFunction, ValueJoiner, TableJoined, Materialized)