Package org.apache.kafka.streams.kstream

Interface ValueJoiner<V1,V2,VR>

Type Parameters:
V1 - first value type
V2 - second value type
VR - joined value type
public interface ValueJoiner<V1,V2,VR>
The ValueJoiner interface for joining two values into a new value of arbitrary type. This is a stateless operation, i.e, apply(Object, Object) is invoked individually for each joining record-pair of a KStream-KStream, KStream-KTable, or KTable-KTable join.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    VR
    apply(V1 value1, V2 value2)
    Return a joined value consisting of value1 and value2.

  • Method Details

    • apply

      VR apply(V1 value1, V2 value2)
      Return a joined value consisting of value1 and value2.
      Parameters:
      value1 - the first value for joining
      value2 - the second value for joining
      Returns:
      the joined value