尚硅谷大数据技术之电信客服

15) 创建类:LRUCache

package com.atguigu.utils;

 

import java.util.LinkedHashMap;

import java.util.Map;

 

public class LRUCache<K, V> extends LinkedHashMap<K, V> {

    private static final long serialVersionUID = -5907797767584803517L;

    protected int maxElements;

 

    public LRUCache(int maxSize) {

        super(maxSize, 0.75F, true);

        this.maxElements = maxSize;

    }

 

    /*

     * (non-Javadoc)

     *

     * @see java.util.LinkedHashMap#removeEldestEntry(java.util.Map.Entry)

     */

    @Override

    protected boolean removeEldestEntry(Map.Entry<K, V> eldest) {

        return (size() > this.maxElements);

    }

}

16) 创建类:Constants

package com.atguigu.constants;

 

public class Constants {

    public static final int JDBC_DEFAULT_BATCH_NUMBER = 500;

}

3.3.5 运行测试

1) 将mysql驱动包放入到hadoop根目录的lib目录下

$ cp -a /opt/module/mysql-libs/mysql-connector-java-5.1.27/mysql-connector-java-5.1.27-bin.jar ./lib

2) 提交任务

$ bin/yarn jar ~/call/jars/ct_analysis-1.0-SNAPSHOT.jar

 com.atguigu.analysis.runner.CountDurationRunner -libjars ./lib/*

观察Mysql中的结果。