Interface ValueJoinerWithStreamAndMappedKey<StreamKey, TableKey, StreamValue, TableValue, VOut>

Type Parameters:

StreamKey - the type of the original KStream record key

TableKey - the type of the mapped join key (the GlobalKTable lookup key)

StreamValue - the type of the first (stream) value

TableValue - the type of the second (table) value

VOut - the type of the joined result value

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
@Public
public interface ValueJoinerWithStreamAndMappedKey<StreamKey, TableKey, StreamValue, TableValue, VOut>

The ValueJoinerWithStreamAndMappedKey interface for joining two values into a new value of arbitrary type, with access to both the original KStream record and the mapped join key. Used by KStream-GlobalKTable joins, where the join key is produced by a KeyValueMapper and does not necessarily equal the KStream record's key.

Method Summary

Modifier and Type	Method	Description
VOut	apply(StreamKey streamKey, TableKey mappedKey, StreamValue value1, TableValue value2)	Return a joined value derived from mappedKey, streamKey, value1 and value2.

Method Details

apply

VOut apply(StreamKey streamKey,
 TableKey mappedKey,
 StreamValue value1,
 TableValue value2)

Return a joined value derived from mappedKey, streamKey, value1 and value2.

Parameters:

streamKey - the KStream record's key. Read-only.

mappedKey - the join key produced by the KeyValueMapper (i.e. the GlobalKTable lookup key); may be null for a left-join when the mapper returns null. Read-only.

value1 - the KStream record's value

value2 - the matching GlobalKTable value, or null for a left-join with no match

Returns:

the joined value