K
- the type of join keyM
- type of input messageR
- type of the table recordJM
- type of join results@InterfaceStability.Unstable public interface StreamTableJoinFunction<K,M,R,JM> extends InitableFunction, ClosableFunction, java.io.Serializable
Modifier and Type | Method and Description |
---|---|
JM |
apply(M message,
R record)
Joins the provided messages and table record, returns the joined message.
|
K |
getMessageKey(M message)
Retrieve the join key from incoming messages
|
K |
getRecordKey(R record)
Retrieve the join key from table record
|
init
close
JM apply(M message, R record)
message
- the input messagerecord
- the table record valueK getMessageKey(M message)
message
- incoming message