增加ip转换

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

@@ -236,5 +236,18 @@ public class InterceptorDataFormatUtil {
 		arrayList.add(jsonObj.getString("create_time"));
 		return arrayList;
 	}
+
+	public static List<String> eventIpConvertDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("id"));
+		arrayList.add(jsonObj.getString("ip"));
+		arrayList.add(jsonObj.getString("area_name"));
+		arrayList.add(jsonObj.getString("device_id"));
+		arrayList.add(jsonObj.getString("cid"));
+		arrayList.add(jsonObj.getString("phone"));
+		arrayList.add(jsonObj.getString("nick"));
+		arrayList.add(jsonObj.getString("create_date"));
+		return arrayList;
+	}
 	
 }

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

@@ -49,6 +49,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.deviceOverlapDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "cidGroupOverlap")) {
 			return dataSplit(InterceptorDataFormatUtil.cidGroupOverlapDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "eventIpConvert")) {
+			return dataSplit(InterceptorDataFormatUtil.eventIpConvertDataFormat(jsonObj));
 		}
 		return resultStr;
 	}