zoukankan      html  css  js  c++  java
  • 代码片段2

    package com.glsx.main;

    import com.glsx.constants.Constant;
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.*;
    import org.apache.hadoop.hbase.client.Admin;
    import org.apache.hadoop.hbase.client.Connection;
    import org.apache.hadoop.hbase.client.ConnectionFactory;
    import org.apache.hadoop.hbase.util.Bytes;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;

    import java.io.IOException;
    import java.util.Map;

    public class CompactMain {
    private static final Logger LOG = LoggerFactory.getLogger(CompactMain.class);

    public static void main(String[] args) throws IOException {
        LOG.info("The job starting...");
        long begin = System.currentTimeMillis();
    
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "hadoop-offline-60,hadoop-offline-61,hadoop-offline-62");
    
        Connection connection = ConnectionFactory.createConnection(conf);
        Admin admin = connection.getAdmin();
    
        int numTotalCompact = 0;
        ClusterStatus clusterStatus = admin.getClusterStatus();
        for (ServerName sn : clusterStatus.getServers()) {
            int maxCompactByServer = 0;
            ServerLoad serverLoad = clusterStatus.getLoad(sn);
            for (Map.Entry<byte[], RegionLoad> regionLoadEntry : serverLoad.getRegionsLoad().entrySet()) {
                RegionLoad rlValue = regionLoadEntry.getValue();
                String regionName = Bytes.toStringBinary(rlValue.getName());
                if (rlValue.getStorefiles() >= Constant.NUM_STOREFILES) {
                    ++numTotalCompact;
                    ++maxCompactByServer;
                    LOG.info("HostName=" + sn.getHostname() + ",regionName=" + regionName + ", storefilesCount=" + rlValue.getStorefiles());
    
                    admin.majorCompactRegion(rlValue.getName());
    
                    if (maxCompactByServer == Constant.MAX_COMPACT_BY_SERVER) break;
                }
            }
        }
    
        LOG.info("numTotalCompact=" + numTotalCompact);
    
        admin.close();
        connection.close();
    
        LOG.info("The job is ended, total cost time :" + (System.currentTimeMillis()-begin)/1000 + "s");
    }
    

    }

  • 相关阅读:
    2017福建夏令营Day7(数论)
    2017福建夏令营Day3(搜索)
    【FZSZ2017暑假提高组Day9】猜数游戏(number)
    【FZSZ2017暑假提高组Day6】bd
    POJ 3660 传递闭包问题
    NOIP 提高组 2002 均分纸牌
    POJ 2387 Til the Cows Come Home
    NOIP 2016 Day2 T1 组合数问题
    06--ubuntu的sqlite安装
    ARM架构与体系学习(二)——3级流水线
  • 原文地址:https://www.cnblogs.com/riordon/p/11844734.html
Copyright © 2011-2022 走看看