Skip to content

eagleEye / flume-interceptor

Go to a project
Commit 40645f73 by 魏建枢
Options

增加字段

parent b1089a65
Inline Side-by-side
Showing with 4 additions and 2 deletions
flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java
...@@ -32,7 +32,8 @@ public class InterceptorDataFormatUtil { ...@@ -32,7 +32,8 @@ public class InterceptorDataFormatUtil {
arrayList.add(jsonObj.getString("other_info")); arrayList.add(jsonObj.getString("other_info"));
arrayList.add(jsonObj.getString("device_info")); arrayList.add(jsonObj.getString("device_info"));
arrayList.add(jsonObj.getString("env_info")); arrayList.add(jsonObj.getString("env_info"));
arrayList.add(jsonObj.getString("user_name")); arrayList.add(jsonObj.getString("user_properties"));
arrayList.add(jsonObj.getString("unique_id"));
return arrayList; return arrayList;
} }
...@@ -55,7 +56,8 @@ public class InterceptorDataFormatUtil { ...@@ -55,7 +56,8 @@ public class InterceptorDataFormatUtil {
arrayList.add(jsonObj.getString("strategy_version")); arrayList.add(jsonObj.getString("strategy_version"));
arrayList.add(jsonObj.getString("event_list")); arrayList.add(jsonObj.getString("event_list"));
arrayList.add(jsonObj.getString("route_ip")); arrayList.add(jsonObj.getString("route_ip"));
arrayList.add(jsonObj.getString("user_name")); arrayList.add(jsonObj.getString("user_properties"));
arrayList.add(jsonObj.getString("unique_id"));
return arrayList; return arrayList;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment