kotka-streams-extensions/dev.adamko.kotka.extensions.tables

Package-level declarations

Types

A function that extracts the key (otherK) from this table's value (V). If the result is null, the update is ignored as invalid. See KTable.join

fun <K, V> KTable<K, V>.filter( name: String? = null, materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>? = null, predicate: (K, V) -> Boolean): KTable<K, V>

fun <K, V> KTable<K, V>.filterNot( name: String? = null, materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>? = null, predicate: (K, V) -> Boolean): KTable<K, V>

fun <K, V, otherV, outV> KTable<K, V>.join( other: KTable<K, otherV>, name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, V, otherK, otherV, outV> KTable<K, V>.join( other: KTable<otherK, otherV>, name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, foreignKeyExtractor: ForeignKeyExtractor<V, otherK>, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, V, otherK, otherV, outV> KTable<K, V>.join( other: KTable<otherK, otherV>, tableJoined: TableJoined<K, otherK>? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, foreignKeyExtractor: ForeignKeyExtractor<V, otherK>, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, V, otherV, outV> KTable<K, V>.leftJoin( other: KTable<K, otherV>, name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, V, otherK, otherV, outV> KTable<K, V>.leftJoin( other: KTable<otherK, otherV>, name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, foreignKeyExtractor: (V) -> otherK, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, V, otherK, otherV, outV> KTable<K, V>.leftJoin( other: KTable<otherK, otherV>, tableJoined: TableJoined<K, otherK>? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, foreignKeyExtractor: (V) -> otherK, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>

fun <K, inV, outV> KTable<K, inV>.mapValues( name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, mapper: (readOnlyKey: K, value: inV) -> outV): KTable<K, outV>

fun <K, V, otherV, outV> KTable<K, V>.outerJoin( other: KTable<K, otherV>, name: String? = null, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>? = null, joiner: ValueJoiner<V, otherV, outV>): KTable<K, outV>