Hi all:
KeyBy process function
EventKeyedBroadcastProcessFunction {
private transient mapstate = null;
public void open(Configuration parameters) throws Exception {
// initial map state
}
public void processElement() {
// can't get onTimer() function set state key
value
}
public void onTimer() {
// set map state key value first
}
}
why processElement function can't get onTimer function sets value ?
thanks.