sink = context.newPluginInstance(sinkPluginId);
RealtimeContext sinkContext = new WorkerRealtimeContext(context, metrics, sinkPluginId);
LOG.debug("Sink Stage : {}", stage.getName());
LOG.debug("Sink Class : {}", sink.getClass().getName());
sink.initialize(sinkContext);
<BUG>sink = new TrackedRealtimeSink(sink, metrics, stage.getName());
}</BUG>
private List<Transformation> initializeTransforms(WorkerContext context, List<ETLStage> stages) throws Exception {
List<String> transformIds = GSON.fromJson(context.getRuntimeArguments().get(Constants.Transform.PLUGINIDS),
STRING_LIST_TYPE);

sink = context.newPluginInstance(sinkPluginId);
RealtimeContext sinkContext = new WorkerRealtimeContext(context, metrics, sinkPluginId);
LOG.debug("Sink Stage : {}", stage.getName());
LOG.debug("Sink Class : {}", sink.getClass().getName());
sink.initialize(sinkContext);
sink = new TrackedRealtimeSink(sink, metrics, PluginID.from(sinkPluginId));
}
private List<Transformation> initializeTransforms(WorkerContext context, List<ETLStage> stages) throws Exception {
List<String> transformIds = GSON.fromJson(context.getRuntimeArguments().get(Constants.Transform.PLUGINIDS),
STRING_LIST_TYPE);
