代码提交

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

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