LOG.debug("Transform Stage : {}", stageConfig.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
pipeline.add(transform);
transforms.add(transform);
<BUG>stageMetrics.add(new StageMetrics(mapperMetrics, StageMetrics.Type.TRANSFORM, stageConfig.getName()));
}</BUG>
}
@Override
public void map(Object key, Object value, Context context) throws IOException, InterruptedException {

LOG.debug("Transform Stage : {}", stageConfig.getName());
LOG.debug("Transform Class : {}", transform.getClass().getName());
transform.initialize(transformContext);
pipeline.add(transform);
transforms.add(transform);
stageMetrics.add(new StageMetrics(mapperMetrics, PluginID.from(transformId)));
}
}
@Override
public void map(Object key, Object value, Context context) throws IOException, InterruptedException {
