Java源码示例:org.apache.kylin.rest.response.HBaseResponse

示例1
@SuppressWarnings("unused") // used by reflection
public static HBaseResponse getHBaseInfo(String tableName, KylinConfig config) throws IOException {
    if (!config.getStorageUrl().getScheme().equals("hbase"))
        return null;

    Connection conn = HBaseUnionUtil.getConnection(config, tableName);
    return getHBaseInfo(tableName, conn);
}
 
示例2
public static boolean checkEquals(HBaseResponse hbaseR1, HBaseResponse hbaseR2) {
    if (hbaseR1 == hbaseR2)
        return true;
    return Objects.equals(hbaseR1.getTableName(), hbaseR2.getTableName())
            && hbaseR1.getTableSize() == hbaseR2.getTableSize()
            && hbaseR1.getRegionCount() == hbaseR2.getRegionCount();
}
 
示例3
private boolean checkHTableEquals(String tableName) throws IOException {
    HBaseResponse respSrc = HBaseInfoUtil.getHBaseInfo(tableName, srcCluster.hbaseConn);
    HBaseResponse respDst = HBaseInfoUtil.getHBaseInfo(tableName, dstCluster.hbaseConn);
    return HBaseInfoUtil.checkEquals(respSrc, respDst);
}