假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/

flink小助手 2019-01-10 16:36:49 3474

假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction
和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/

分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:25:11

    先调用 initializeState
    社区不建议使用这个类了,已经 deprecated 了,如果你用 ListCheckpointed 的话,注释里写的比较清楚

    0 0
云计算
使用钉钉扫一扫加入圈子
+ 订阅

时时分享云计算技术内容,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

推荐文章