import co.cask.cdap.template.etl.common.StageMetrics;</BUG>
public class TrackedRealtimeSink<T> extends RealtimeSink<T> {
private final RealtimeSink<T> sink;
private final Metrics metrics;
<BUG>public TrackedRealtimeSink(RealtimeSink<T> sink, Metrics metrics, String name) {
</BUG>
this.sink = sink;
<BUG>this.metrics = new StageMetrics(metrics, StageMetrics.Type.SINK, name);
</BUG>
}

package co.cask.cdap.template.etl.realtime;
import co.cask.cdap.api.metrics.Metrics;
import co.cask.cdap.template.etl.api.realtime.DataWriter;
import co.cask.cdap.template.etl.api.realtime.RealtimeSink;
import co.cask.cdap.template.etl.common.PluginID;
import co.cask.cdap.template.etl.common.StageMetrics;
public class TrackedRealtimeSink<T> extends RealtimeSink<T> {
private final RealtimeSink<T> sink;
private final Metrics metrics;
public TrackedRealtimeSink(RealtimeSink<T> sink, Metrics metrics, PluginID id) {
this.sink = sink;
this.metrics = new StageMetrics(metrics, id);
}
