（与如何在flink中创建动态度量有关）
我有一条小溪 events(someid:String, name:String) 出于监控的原因，我需要每个事件id有一个计数器。在所有的flink文档和示例中，我可以看到，例如，计数器在 open 一个Map函数。
但在我的情况下，我不能初始化计数器，因为我需要每个eventid一个，我不知道提前值。而且，我知道每次偶数通过时创建一个新的计数器是多么昂贵 map() Map函数的方法。最后，我不能保留计数器的“缓存”，因为它太大了。
理想情况下，我会喜欢这样的东西：

class Event(id: String, name: String)
class ExampleMapFunction extends RichMapFunction[Event, Event] {
  @transient private var counter: Counter = _
  override def open(parameters: Configuration): Unit = {
    counter = new Counter()
  }
  override def map(event: Event): Event = {
    counter.inc(event.id)
    event
  }
}

或者基本上我可以实现我自己的计数器，让我通过一个维度？如果是，怎么做？
对于这种用例有什么建议或最佳实践吗？