帮我编写编写Flume拦截器

下面是一个简单的Flume拦截器示例，它将日志记录在文件中并添加一个时间戳：

package com.example.flume.interceptor;

import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.interceptor.Interceptor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

public class TimestampInterceptor implements Interceptor {

    private static final Logger logger = LoggerFactory.getLogger(TimestampInterceptor.class);

    private FileWriter fileWriter;

    private TimestampInterceptor(FileWriter fileWriter) {
        this.fileWriter = fileWriter;
    }

    @Override
    public void initialize() {
        // 初始化方法，可以用于读取配置文件等
    }

    @Override
    public Event intercept(Event event) {
        // 对每个事件进行拦截处理
        String body = new String(event.getBody());
        String timestamp = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
        String log = String.format("[%s] %s", timestamp, body);

        try {
            fileWriter.write(log);
            fileWriter.flush();
        } catch (IOException e) {
            logger.error("Failed to write log to file", e);
        }

        return event;
    }

    @Override
    public List<Event> intercept(List<Event> events) {
        // 对事件列表进行批量处理
        for (Event event : events) {
            intercept(event);
        }
        return events;
    }

    @Override
    public void close() {
        // 关闭方法，可以用于释放资源等
        try {
            fileWriter.close();
        } catch (IOException e) {
            logger.error("Failed to close file writer", e);
        }
    }

    public static class Builder implements Interceptor.Builder {

        private FileWriter fileWriter;

        @Override
        public void configure(Context context) {
            // 配置方法，可以用于读取参数等
            String fileName = context.getString("fileName", "flume.log");
            try {
                File file = new File(fileName);
                if (!file.exists()) {
                    file.createNewFile();
                }
                fileWriter = new FileWriter(file, true);
            } catch (IOException e) {
                logger.error("Failed to create file writer", e);
            }
        }

        @Override
        public Interceptor build() {
            // 构建方法，返回一个Interceptor实例
            return new TimestampInterceptor(fileWriter);
        }
    }
}

这个拦截器会在Flume接收到事件后将日志写入文件中，并在每行日志前添加一个时间戳。在Flume配置文件中使用这个拦截器的方法如下：

agent.sources = source1
agent.channels = channel1
agent.sinks = sink1

agent.sources.source1.type = ...
agent.sources.source1.interceptors = interceptor1
agent.sources.source1.interceptors.interceptor1.type = com.example.flume.interceptor.TimestampInterceptor$Builder
agent.sources.source1.interceptors.interceptor1.fileName = /path/to/log/file

agent.channels.channel1.type = ...
agent.channels.channel1.capacity = ...
agent.channels.channel1.transactionCapacity = ...

agent.sinks.sink1.type = ...
agent.sinks.sink1.channel = channel1