如何在Flume的自定义接收器类中为每个批次重置变量

import org.apache.flume.*;
import org.apache.flume.conf.Configurable;
import org.apache.flume.event.SimpleEvent;
import org.apache.flume.source.AbstractSource;

public class CustomSource extends AbstractSource implements Configurable, EventDrivenSource {

    private String variableToReset;

    @Override
    public void configure(Context context) {
        // 从配置文件中获取需要重置的变量
        variableToReset = context.getString("variable.to.reset");
    }

    @Override
    public synchronized void start() {
        // 初始化变量
        // ...
        super.start();
    }

    @Override
    public synchronized void stop() {
        // 停止操作
        // ...
        super.stop();
    }

    @Override
    public synchronized void process() {
        // 获取ChannelProcessor对象，用于将事件发送到Channel
        ChannelProcessor channelProcessor = getChannelProcessor();

        // 处理每个批次的数据
        while (true) {
            // 从Channel中获取事件
            Event event = channelProcessor.getChannel().take();

            // 处理事件
            // ...

            // 重置变量
            variableToReset = null;

            // 将处理后的事件发送到Channel
            channelProcessor.processEvent(event);
        }
    }
}