支持json类型同步

This commit is contained in:
dengyixiang 2023-07-04 15:10:43 +08:00
parent f6d21f112d
commit 285a46cd65

View File

@ -173,6 +173,8 @@ public class MongoDBReader extends Reader {
String tempArrayStr = Joiner.on(splitter).join(array);
record.addColumn(new StringColumn(tempArrayStr));
}
}else if ("json".equalsIgnoreCase(column.getString("type"))) {
record.addColumn(new StringColumn(JSON.toJSONString(tempCol)));
} else {
record.addColumn(new StringColumn(tempCol.toString()));
}