Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Won't Fix
-
None
-
None
Description
Add the CountMetric for the first step of storm metrics:
1.Do a wrapper FlinkCountMetric for CountMetric
2.push the RuntimeContext in FlinkTopologyContext to use `addAccumulator` method for registering the metric.