rows.close();
}
}
});
initializeSource(context, config.getSource());
<BUG>List<Transformation> transforms = initializeTransforms(context,

config.getTransforms().or(Lists.<ETLStage>newArrayList()));</BUG>
initializeSink(context, config.getSink());
transformExecutor = new TransformExecutor(transforms, transformMetrics);

rows.close();
}
}
});
initializeSource(context, config.getSource());
List<Transformation> transforms = initializeTransforms(context, config.getTransforms());
initializeSink(context, config.getSink());
transformExecutor = new TransformExecutor(transforms, transformMetrics);
