Using MapState clear, put methods in snapshotState within KeyedCoProcessFunction, valid or not?

2019-11-30 Thread Salva Alcántara
Given: ```scala class MyOperator extends KeyedCoProcessFunction[String, ModelDef, Data, Prediction] with CheckpointedFunction { // To hold loaded models @transient private var models: HashMap[(String, String), Model] = _ // For serialization purposes @transient private var modelsBytes

1111

2019-11-30 Thread wenfeng wang
1

subscribe flink

2019-11-30 Thread wenfeng wang
subscribe flink