Huang Wei created FLINK-2720: -------------------------------- Summary: Add Storm-CountMetric in flink-stormcompatibility Key: FLINK-2720 URL: https://issues.apache.org/jira/browse/FLINK-2720 Project: Flink Issue Type: New Feature Components: Storm Compatibility Reporter: Huang Wei Assignee: Huang Wei Fix For: 0.10
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. -- This message was sent by Atlassian JIRA (v6.3.4#6332)