diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/DataxJsonHelper.java b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/DataxJsonHelper.java index 24f8b4b7..27b91a24 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/DataxJsonHelper.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/DataxJsonHelper.java @@ -179,13 +179,13 @@ public class DataxJsonHelper implements DataxJsonInterface { public Map buildHiveReader() { DataxHivePojo dataxHivePojo = new DataxHivePojo(); dataxHivePojo.setJdbcDatasource(readerDatasource); - List> columns = Lists.newArrayList(); - readerColumns.forEach(c -> { - Map column = Maps.newLinkedHashMap(); - column.put("name", c.split(Constant.SPLIT_SCOLON)[0]); - column.put("type", c.split(Constant.SPLIT_SCOLON)[1]); + List> columns = Lists.newArrayList(); + for(int i=0;i column = Maps.newLinkedHashMap(); + column.put("index", i); + column.put("type", readerColumns.get(i).split(Constant.SPLIT_SCOLON)[1]); columns.add(column); - }); + } dataxHivePojo.setColumns(columns); dataxHivePojo.setReaderDefaultFS(hiveReaderDto.getReaderDefaultFS()); dataxHivePojo.setReaderFieldDelimiter(hiveReaderDto.getReaderFieldDelimiter()); @@ -208,9 +208,9 @@ public class DataxJsonHelper implements DataxJsonInterface { public Map buildHiveWriter() { DataxHivePojo dataxHivePojo = new DataxHivePojo(); dataxHivePojo.setJdbcDatasource(writerDatasource); - List> columns = Lists.newArrayList(); + List> columns = Lists.newArrayList(); writerColumns.forEach(c -> { - Map column = Maps.newLinkedHashMap(); + Map column = Maps.newLinkedHashMap(); column.put("name", c.split(Constant.SPLIT_SCOLON)[0]); column.put("type", c.split(Constant.SPLIT_SCOLON)[1]); columns.add(column); diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/reader/HiveReader.java b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/reader/HiveReader.java index 1c87d40b..95828d61 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/reader/HiveReader.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/reader/HiveReader.java @@ -15,7 +15,7 @@ import java.util.Map; public class HiveReader extends BaseReaderPlugin implements DataxReaderInterface { @Override public String getName() { - return "hivereader"; + return "hdfsreader"; } @Override diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/writer/HiveWriter.java b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/writer/HiveWriter.java index 3a596e7f..20e9673d 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/writer/HiveWriter.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/tool/datax/writer/HiveWriter.java @@ -15,7 +15,7 @@ import java.util.Map; public class HiveWriter extends BaseWriterPlugin implements DataxWriterInterface { @Override public String getName() { - return "hivewriter"; + return "hdfswriter"; } diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/tool/pojo/DataxHivePojo.java b/datax-admin/src/main/java/com/wugui/datax/admin/tool/pojo/DataxHivePojo.java index cd015538..ecb1daf2 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/tool/pojo/DataxHivePojo.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/tool/pojo/DataxHivePojo.java @@ -20,7 +20,7 @@ public class DataxHivePojo { /** * hive列名 */ - private List> columns; + private List> columns; /** * 数据源信息