0
点赞
收藏
分享

微信扫一扫

flink加载外部数据源

西红柿上校 2022-02-17 阅读 98
flink

flink加载外部数据源
override def open(parameters: Configuration): Unit = {
logger.info(“init…”)
query()
// new Timer
val timer = new Timer(true)
// schedule is 10 second 定义了一个10秒的定时器,定时执行查询数据库的方法
timer.schedule(new TimerTask {
override def run(): Unit = {
query()
}
}, 10000, 10000)

  }

**可以在richfunction的open方法中,通过该方法实现。
第二个参数是延迟多少执行,第三个参数才是循环执行的。

举报

相关推荐

0 条评论