flume的sink测试赫赫有名-CSDN博客

网站介绍:public class MySink extends AbstractSink implements Configurable {//前缀private String prefix;//后缀private String suffix;//创建你logger对象private static final Logger LOG = LoggerFactory.getLogger(Abstr...