RealtimeTransformContext transformContext = new RealtimeTransformContext(context, metrics, transformId);
LOG.debug("Transform Stage : {}", stage.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
transforms.add(transform);
<BUG>transformMetrics.add(new StageMetrics(metrics, StageMetrics.Type.TRANSFORM, stage.getName()));
} catch (InstantiationException e) {</BUG>
LOG.error("Unable to instantiate Transform : {}", stage.getName(), e);
Throwables.propagate(e);
}

RealtimeTransformContext transformContext = new RealtimeTransformContext(context, metrics, transformId);
LOG.debug("Transform Stage : {}", stage.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
transforms.add(transform);
transformMetrics.add(new StageMetrics(metrics, PluginID.from(transformId)));
} catch (InstantiationException e) {
LOG.error("Unable to instantiate Transform : {}", stage.getName(), e);
Throwables.propagate(e);
