class FlinkMetricContainer {

	public void updateMetrics(String stepName, List<MonitoringInfo> monitoringInfos) {
		getMetricsContainer(stepName).update(monitoringInfos);
		updateMetrics(stepName);
	}

	public  FlinkMetricContainer(MetricGroup metricGroup);

}