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);
}