增加设备id节点

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java

@@ -61,7 +61,6 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 	
 	
-	
 	public static List<String> zipperStrategyDataFormat(JSONObject jsonObj) {
 	public static List<String> zipperStrategyDataFormat(JSONObject jsonObj) {
 		List<String> arrayList = new ArrayList<>();
 		List<String> arrayList = new ArrayList<>();
 		arrayList.add(jsonObj.getString("group_id"));
 		arrayList.add(jsonObj.getString("group_id"));
@@ -74,7 +73,6 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 
 
-
 	public static List<String> zipperDeviceFingerprintDataFormat(JSONObject jsonObj) {
 	public static List<String> zipperDeviceFingerprintDataFormat(JSONObject jsonObj) {
 		List<String> arrayList = new ArrayList<>();
 		List<String> arrayList = new ArrayList<>();
 		arrayList.add(jsonObj.getString("brand"));
 		arrayList.add(jsonObj.getString("brand"));
@@ -88,4 +86,16 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 
 
+	public static List<String> deviceIdNodeDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("parent_device_id"));
+		arrayList.add(jsonObj.getString("parent_uid"));
+		arrayList.add(jsonObj.getString("child_device_id"));
+		arrayList.add(jsonObj.getString("child_uid"));
+		arrayList.add(jsonObj.getString("unique_id"));
+		arrayList.add(jsonObj.getString("create_time"));
+		arrayList.add(jsonObj.getString("send_time"));
+		return arrayList;
+	}
+	
 }
 }

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorSelector.java

@@ -25,6 +25,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "eventLog")) {
 		}else if(StringUtils.equals(flume_type, "eventLog")) {
 			return dataSplit(InterceptorDataFormatUtil.eventLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.eventLogDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "deviceIdNode")) {
+			return dataSplit(InterceptorDataFormatUtil.deviceIdNodeDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}