尚硅谷大数据技术之电信客服
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中的结果。