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.

Reply via email to