增加拦截器

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

@@ -207,4 +207,18 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 	
 	
+	public static List<String> bloggerVideoDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("video_id"));
+		arrayList.add(jsonObj.getString("page_url"));
+		arrayList.add(jsonObj.getString("duration"));
+		arrayList.add(jsonObj.getString("likeCount"));
+		arrayList.add(jsonObj.getString("viewCount"));
+		arrayList.add(jsonObj.getString("timesTamp"));
+		arrayList.add(jsonObj.getString("creatTime"));
+		arrayList.add(jsonObj.getString("caption"));
+		arrayList.add(jsonObj.getString("platform"));
+		return arrayList;
+	}
+	
 }
 }

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

@@ -43,6 +43,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.userListDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.userListDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "userInvitation")) {
 		}else if(StringUtils.equals(flume_type, "userInvitation")) {
 			return dataSplit(InterceptorDataFormatUtil.userInvitationDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.userInvitationDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "blogger_video")) {
+			return dataSplit(InterceptorDataFormatUtil.bloggerVideoDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}