gfwleak/galaxy-tsg-olap-storm-log-stream-completion
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

动态获取schema代码更新

Browse Source
This commit is contained in:
李玺康
2019-12-20 12:49:30 +08:00
parent b1cbb95ed1
commit a12f82ae8a
1 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/cn/ac/iie/utils/general/TransFormUtils.java
View File

@@ -41,9 +41,7 @@ public class TransFormUtils {
private static Object mapObject = JsonParseUtil.generateObject(map); private static Object mapObject = JsonParseUtil.generateObject(map);
//获取任务列表 //获取任务列表
private static ArrayList<String[]> jobList = JsonParseUtil.getJobListFromHttp(FlowWriteConfig.SCHEMA_HTTP); private static ArrayList<String[]> jobList = JsonParseUtil.getJobListFromHttp(FlowWriteConfig.SCHEMA_HTTP);
//需要用到的值
public static Object use;
public static Object appendTo;
/** /**
* 解析日志，并补全 * 解析日志，并补全
@@ -69,9 +67,9 @@ public class TransFormUtils {
try { try {
for (String[] strings : jobList) { for (String[] strings : jobList) {
//参数的值 //参数的值
use = JsonParseUtil.getValue(object,strings[0]); Object use = JsonParseUtil.getValue(object,strings[0]);
//补全的字段的值 //补全的字段的值
appendTo = JsonParseUtil.getValue(object,strings[1]); Object appendTo = JsonParseUtil.getValue(object,strings[1]);
if (strings[2].equals("current_timestamp")) { if (strings[2].equals("current_timestamp")) {
JsonParseUtil.setValue(object, strings[1], getCurrentTime()); JsonParseUtil.setValue(object, strings[1], getCurrentTime());
} else if (strings[2].equals("snowflake_id")) { } else if (strings[2].equals("snowflake_id")) {
@@ -95,9 +93,6 @@ public class TransFormUtils {
} }
} }
//初始化一下
use = null;
appendTo = null;
return JSONObject.toJSONString(object); return JSONObject.toJSONString(object);
// System.out.println("补全之后 ===》 "+JSON.toJSONString(object)); // System.out.println("补全之后 ===》 "+JSON.toJSONString(object));