K
- type of the join keyM
- type of the input messageJM
- type of the message to join withRM
- type of the joined message@InterfaceStability.Unstable public interface JoinFunction<K,M,JM,RM> extends InitableFunction, ClosableFunction, java.io.Serializable
Modifier and Type | Method and Description |
---|---|
RM |
apply(M message,
JM otherMessage)
Joins the provided messages and returns the joined message.
|
K |
getFirstKey(M message)
Get the join key for messages in the first input stream.
|
K |
getSecondKey(JM message)
Get the join key for messages in the second input stream.
|
init
close
RM apply(M message, JM otherMessage)
message
- the input messageotherMessage
- the message to join withK getFirstKey(M message)
message
- the message in the first input stream