240 发简信
IP属地:河南
  • 120
    Flink 端对端一致性

    前言 Flink的检查点和恢复机制定期的会保存应用程序状态的一致性检查点。在故障的情况下,应用程序的状态将会从最近一次完成的检查点恢复,并继续处理。尽管如此,可以使用检查点来...

  • 120
    Scala中闭包

    在Scala中,函数引入传入的参数是再正常不过的事情了,比如(x: Int) => x > 0中,唯一在函数体x > 0中用到的变量是x,即这个函数的唯一参数。 除此之外,S...