public class GmallFlumeInterceptor implements Interceptor {
@Override
public void initialize() {
}
@Override
public Event intercept(Event event) {
byte[] body = event.getBody();
String log = new String(body, StandardCharsets.UTF_8);
if (JSONUtil.isJson(log)){
return event;
}else{
return null;
}
}
@Override
public List<Event> intercept(List<Event> list) {
list.removeIf(event -> intercept(event) == null);
return list;
}
public static class Builder implements Interceptor.Builder{
@Override
public Interceptor build() {
return new GmallFlumeInterceptor();
}
@Override
public void configure(Context context) {
}
}
@Override
public void close() {
}
}