作者:高淑美萱士建志 | 来源:互联网 | 2023-07-15 12:07
本文整理了Java中co.cask.cdap.data2.util.hbase.HBaseTableUtil.getVersion()方法的一些代码示例,展示了
本文整理了Java中co.cask.cdap.data2.util.hbase.HBaseTableUtil.getVersion()
方法的一些代码示例,展示了HBaseTableUtil.getVersion()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTableUtil.getVersion()
方法的具体详情如下:
包路径:co.cask.cdap.data2.util.hbase.HBaseTableUtil
类名称:HBaseTableUtil
方法名:getVersion
HBaseTableUtil.getVersion介绍
暂无
代码示例
代码示例来源:origin: cdapio/cdap
public Version getVersion(HTableDescriptor tableDescriptor) {
// 1) First, try to use cdap.version property on HBase table.
// 2) If cdap.version property is not available, then it is 2.7 or 2.6 & older.
// 2a) If table has no increment handler coprocessor, it is 2.6 or older
// 2b) If table has increment handler coprocessor, it is 2.7
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
// note: major version is 0 if table doesn't have the cdap version property
if (version.getMajor() > 0) {
if (version.getMajor() <2) {
return Version.VERSION_2_6_OR_LOWER;
}
if (version.getMajor() == 2 && version.getMinor() <= 6) {
return Version.VERSION_2_6_OR_LOWER;
}
if (version.getMajor() == 2 && version.getMinor() <= 7) {
return Version.VERSION_2_7;
}
return Version.VERSION_2_8_OR_HIGHER;
}
Map cpsInfo = HBaseTableUtil.getCoprocessorInfo(tableDescriptor);
if (cpsInfo.containsKey(tableUtil.getIncrementHandlerClassForVersion().getName())) {
// note: if the version is 2.8 or higher, it would have cdap.version property
return Version.VERSION_2_7;
}
return Version.VERSION_2_6_OR_LOWER;
}
}
代码示例来源:origin: co.cask.cdap/cdap-data-fabric
public Version getVersion(HTableDescriptor tableDescriptor) {
// 1) First, try to use cdap.version property on HBase table.
// 2) If cdap.version property is not available, then it is 2.7 or 2.6 & older.
// 2a) If table has no increment handler coprocessor, it is 2.6 or older
// 2b) If table has increment handler coprocessor, it is 2.7
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
// note: major version is 0 if table doesn't have the cdap version property
if (version.getMajor() > 0) {
if (version.getMajor() <2) {
return Version.VERSION_2_6_OR_LOWER;
}
if (version.getMajor() == 2 && version.getMinor() <= 6) {
return Version.VERSION_2_6_OR_LOWER;
}
if (version.getMajor() == 2 && version.getMinor() <= 7) {
return Version.VERSION_2_7;
}
return Version.VERSION_2_8_OR_HIGHER;
}
Map cpsInfo = HBaseTableUtil.getCoprocessorInfo(tableDescriptor);
if (cpsInfo.containsKey(tableUtil.getIncrementHandlerClassForVersion().getName())) {
// note: if the version is 2.8 or higher, it would have cdap.version property
return Version.VERSION_2_7;
}
return Version.VERSION_2_6_OR_LOWER;
}
}
代码示例来源:origin: co.cask.cdap/cdap-data-fabric
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
String hbaseVersion = HBaseTableUtil.getHBaseVersion(tableDescriptor);
代码示例来源:origin: cdapio/cdap
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
String hbaseVersion = HBaseTableUtil.getHBaseVersion(tableDescriptor);
代码示例来源:origin: co.cask.cdap/cdap-tms
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
String hbaseVersion = HBaseTableUtil.getHBaseVersion(tableDescriptor);
代码示例来源:origin: caskdata/cdap
ProjectInfo.Version version = HBaseTableUtil.getVersion(tableDescriptor);
String hbaseVersion = HBaseTableUtil.getHBaseVersion(tableDescriptor);