private final Map<String, String> transformClassMap;
public ETLBatchTemplate() throws Exception {
sourceClassMap = Maps.newHashMap();
sinkClassMap = Maps.newHashMap();
transformClassMap = Maps.newHashMap();
<BUG>initTable(Lists.<Class>newArrayList(KVTableSource.class, KVTableSink.class, IdentityTransform.class));

}</BUG>
private void initTable(List<Class> classList) throws Exception {
for (Class klass : classList) {

private final Map<String, String> transformClassMap;
public ETLBatchTemplate() throws Exception {
sourceClassMap = Maps.newHashMap();
sinkClassMap = Maps.newHashMap();
transformClassMap = Maps.newHashMap();
initTable(Lists.<Class>newArrayList(KVTableSource.class, KVTableSink.class, IdentityTransform.class,
StructuredRecordToGenericRecordTransform.class));
}
private void initTable(List<Class> classList) throws Exception {
for (Class klass : classList) {
