@@ -0,0 +1,1404 @@
+package pl.schibsted.flume.interceptor.json;%0A%0Aimport org.apache.commons.lang.StringUtils;%0Aimport org.apache.flume.Context;%0Aimport org.apache.flume.conf.ComponentConfiguration;%0Aimport org.joda.time.DateTime;%0Aimport org.joda.time.format.DateTimeFormat;%0Aimport org.joda.time.format.DateTimeFormatter;%0Aimport com.google.common.base.Preconditions;%0A%0Apublic class JsonInterceptorDateTimeFormatSerializer implements%0A        JsonInterceptorSerializer %7B%0A    private DateTimeFormatter inputFormatter;%0A    private DateTimeFormatter outputFormatter;%0A    @Override%0A    public void configure(Context context) %7B%0A        String inputPattern = context.getString(%22inputpattern%22);%0A        String outputPattern = context.getString(%22outputpattern%22);%0A        Preconditions.checkArgument(!StringUtils.isEmpty(inputPattern),%0A                %22Must configure with a valid inputpattern%22);%0A        Preconditions.checkArgument(!StringUtils.isEmpty(outputPattern),%0A                %22Must configure with a valid outputpattern%22);%0A        inputFormatter = DateTimeFormat.forPattern(inputPattern);%0A        outputFormatter = DateTimeFormat.forPattern(outputPattern);%0A    %7D%0A    @Override%0A    public String serialize(String value) %7B%0A        DateTime dateTime = inputFormatter.parseDateTime(value);%0A        return outputFormatter.print(dateTime.getMillis());%0A    %7D%0A    @Override%0A    public void configure(ComponentConfiguration conf) %7B%0A    %7D%0A%7D%0A

Add date time output format serializer