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

Package-level declarations

Types

ForeignKeyExtractor

fun interface ForeignKeyExtractor<V, otherK> : Function1<V, otherK?>

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

Functions

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 <inK, inV, outK, outV> KTable<inK, inV>.groupBy(grouped: Grouped<outK, outV>? = null, selector: KeyValueMapper<inK, inV, KeyValue<outK, outV>>): KGroupedTable<outK, outV>

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>

fun <K, V> KTable<K, V>.toStream(name: String): KStream<K, V?>

fun <inK, V, outK> KTable<inK, V>.toStream(name: String, mapper: KeyValueMapper<inK, V, outK>? = null): KStream<outK, V?>