Transform transform = context.newPluginInstance(transformId);
BatchTransformContext transformContext = new BatchTransformContext(context, mapperMetrics, transformId);
LOG.debug("Transform Stage : {}", stageConfig.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
<BUG>pipeline.add(transform);
transforms.add(transform);
stageMetrics.add(new StageMetrics(mapperMetrics, PluginID.from(transformId)));</BUG>
}
}

Transform transform = context.newPluginInstance(transformId);
BatchTransformContext transformContext = new BatchTransformContext(context, mapperMetrics, transformId);
LOG.debug("Transform Stage : {}", stageConfig.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
StageMetrics stageMetrics = new StageMetrics(mapperMetrics, PluginID.from(transformId));
pipeline.add(new TransformDetail(transformId, transform, stageMetrics));
transforms.add(transform);
}
}
