Hive的存储和MapReduce处理——数据清洗（Part3）

日期：2019.11.15

博客期：117

星期五

　　这两天因为有课，其他的课程需要做实验，所以课下都在做其他科目的实验。

　　不过还是有新的进度的。

　　我研究了IP到城市的格式转换

　　

public class IPUtil {
 
    public static String getCityInfo(String ip){
 
        //db
        //String dbPath = "data/ip2region.db";
        String dbPath = IPUtil.class.getResource("../data/ip2region.db").getPath();
 
        File file = new File(dbPath);
        if ( file.exists() == false ) {
            System.out.println("Error: Invalid ip2region.db file");
        }
 
        //查询算法
        int algorithm = DbSearcher.BTREE_ALGORITHM; //B-tree
                        //DbSearcher.BINARY_ALGORITHM //Binary
                        //DbSearcher.MEMORY_ALGORITYM //Memory
        try {
            DbConfig config = new DbConfig();
            DbSearcher searcher = new DbSearcher(config, dbPath);
 
            //define the method
            Method method = null;
            switch ( algorithm )
            {
            case DbSearcher.BTREE_ALGORITHM:
                method = searcher.getClass().getMethod("btreeSearch", String.class);
                break;
            case DbSearcher.BINARY_ALGORITHM:
                method = searcher.getClass().getMethod("binarySearch", String.class);
                break;
            case DbSearcher.MEMORY_ALGORITYM:
                method = searcher.getClass().getMethod("memorySearch", String.class);
                break;
            }
 
            DataBlock dataBlock = null;
            if ( Util.isIpAddress(ip) == false ) {
                System.out.println("Error: Invalid ip address");
            }
 
            dataBlock  = (DataBlock) method.invoke(searcher, ip);
 
            return dataBlock.getRegion();
 
        } catch (Exception e) {
            e.printStackTrace();
        }
 
        return null;
    }
 
    public static void main(String[] args)  throws Exception{
        System.out.println(getCityInfo("106.39.41.166"));
    }
}

　　result.txt资源我已上传至我的资源文件里。