×

scala

Flink Accumulators累加器、Counters计数器的使用和实现自定义Accumulators、Counters

暮 发表于2024-06-16 浏览5932 评论0
1. 自定义Accumulators 自定义的方式有两种,两种之间除了要求的数据类型不一样,其它都一样 Accumulator<V, R>: 其中V指add的数据的类型、R指结果的类型 SimpleAccumulator<T>: 其中T指add和结果的数据的类型 这里我们使用Accumulator来实现 devBase\Int2LongAccumulator.scala package devBase import org.apache.f