增加社区采集拦截器

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

@@ -97,5 +97,33 @@ public class InterceptorDataFormatUtil {
 		arrayList.add(jsonObj.getString("send_time"));
 		arrayList.add(jsonObj.getString("send_time"));
 		return arrayList;
 		return arrayList;
 	}
 	}
+
+	public static List<String> sminCommunityAiClassDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("primaryId"));
+		arrayList.add(jsonObj.getString("risk"));
+		arrayList.add(jsonObj.getString("label"));
+		arrayList.add(jsonObj.getString("ad_risk"));
+		return arrayList;
+	}
+
+	public static List<String> sminCommunityCollectDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("primaryId"));
+		arrayList.add(jsonObj.getString("userName"));
+		arrayList.add(jsonObj.getString("createTime"));
+		arrayList.add(jsonObj.getString("topics"));
+		arrayList.add(jsonObj.getString("countryName"));
+		arrayList.add(jsonObj.getString("provinceNmae"));
+		arrayList.add(jsonObj.getString("publishBlog"));
+		arrayList.add(jsonObj.getString("authorization"));
+		arrayList.add(jsonObj.getString("content"));
+		arrayList.add(jsonObj.getString("images"));
+		arrayList.add(jsonObj.getString("thumbnailImages"));
+		arrayList.add(jsonObj.getString("reduceImages"));
+		arrayList.add(jsonObj.getString("forwardId"));
+		arrayList.add(jsonObj.getString("forwardType"));
+		return arrayList;
+	}
 	
 	
 }
 }

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

@@ -27,6 +27,10 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.eventLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.eventLogDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "deviceIdNode")) {
 		}else if(StringUtils.equals(flume_type, "deviceIdNode")) {
 			return dataSplit(InterceptorDataFormatUtil.deviceIdNodeDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.deviceIdNodeDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "sminCommunityAiClass")) {
+			return dataSplit(InterceptorDataFormatUtil.sminCommunityAiClassDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "sminCommunityCollect")) {
+			return dataSplit(InterceptorDataFormatUtil.sminCommunityCollectDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}