zoukankan      html  css  js  c++  java
  • Hadoop实战-Flume之自定义Source(十八)

    import java.nio.charset.Charset;
    import java.util.HashMap;
    import java.util.Random;
    
    import org.apache.flume.Context;
    import org.apache.flume.EventDeliveryException;
    import org.apache.flume.PollableSource;
    import org.apache.flume.conf.Configurable;
    import org.apache.flume.event.EventBuilder;
    import org.apache.flume.source.AbstractSource;
    
    public class MySouce extends AbstractSource implements Configurable,
            PollableSource {
    
        @Override
        public long getBackOffSleepIncrement() {
            // TODO Auto-generated method stub
            return 0;
        }
    
        @Override
        public long getMaxBackOffSleepInterval() {
            // TODO Auto-generated method stub
            return 0;
        }
    
        @Override
        public Status process() throws EventDeliveryException {
            try {
    
                while (true) {
    
                    int max = 20;
    
                    int min = 10;
    
                    Random random = new Random();
    
                    int s = random.nextInt(max) % (max - min + 1) + min;
    
                    HashMap<String, String> header = new HashMap<String, String>();
    
                    header.put("id", Integer.toString(s));
    
                    this.getChannelProcessor().processEvent(
                            EventBuilder.withBody(Integer.toString(s),
                                    Charset.forName("UTF-8"), header));
                    Thread.sleep(1000);
                }
    
            } catch (InterruptedException e) {
    
                e.printStackTrace();
    
            }
            return null;
        }
    
        @Override
        public void configure(Context arg0) {
            // TODO Auto-generated method stub
    
        }
    
    }
  • 相关阅读:
    轻配置 Vim
    PHP 使用 wkhtmltopdf/image 把HTML页面转换成 PDF/image 文件
    使用 Mailgun 实现 带附件的Email 发送功能
    LinkedIn 第三方登录(JavaScript SDK)
    react学习2
    前端面试题
    react学习
    前端面试-字符串-逆序-间隔
    前端文件上传相关知识
    js原型prototype问题
  • 原文地址:https://www.cnblogs.com/qq27271609/p/6864192.html
Copyright © 2011-2022 走看看