@Override
    public void setRuntimeContext(RuntimeContext t) {
        this.runtimeContext = t;
        eventDelayGauge = new EventDelayGauge();
        t.getMetricGroup().gauge(MetricConstant.DT_EVENT_DELAY_GAUGE, eventDelayGauge);
    }
Reason:
Date: 2018/10/18
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java