org.apache.samza.operators.functions

Interface JoinFunction<M extends MessageEnvelope,JM extends MessageEnvelope,RM extends MessageEnvelope>

Type Parameters:

M - type of the input MessageEnvelope

JM - type of the MessageEnvelope to join with

RM - type of the joined MessageEnvelope

Functional Interface:

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

@InterfaceStability.Unstable
 @FunctionalInterface
public interface JoinFunction<M extends MessageEnvelope,JM extends MessageEnvelope,RM extends MessageEnvelope>

A function that joins MessageEnvelopes from two MessageStreams and produces a joined MessageEnvelope.

Method Summary

Modifier and Type	Method and Description
RM	apply(M message, JM otherMessage) Join the provided MessageEnvelopes and produces the joined MessageEnvelope.

Method Detail

apply

RM apply(M message,
         JM otherMessage)

Join the provided MessageEnvelopes and produces the joined MessageEnvelope.

Parameters:

message - the input MessageEnvelope

otherMessage - the MessageEnvelope to join with

Returns:

the joined MessageEnvelope