org.apache.hadoop.hbase.io.hfile.HFile.getFormatVersion()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(118)

本文整理了Java中org.apache.hadoop.hbase.io.hfile.HFile.getFormatVersion()方法的一些代码示例，展示了HFile.getFormatVersion()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HFile.getFormatVersion()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.io.hfile.HFile
类名称：HFile
方法名：getFormatVersion

HFile.getFormatVersion介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

/**
 * check configured hfile format version before to do compaction
 * @throws IOException throw IOException
 */
private void checkHFileFormatVersionForMob() throws IOException {
 if (HFile.getFormatVersion(master.getConfiguration()) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
  LOG.error("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS
    + " is required for MOB compaction. Compaction will not run.");
  throw new IOException("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS
    + " is required for MOB feature. Consider setting " + HFile.FORMAT_VERSION_KEY
    + " accordingly.");
 }
}

代码示例来源：origin: apache/hbase

public static boolean isCellAuthorizationSupported(Configuration conf) {
 return AccessChecker.isAuthorizationSupported(conf) &&
   (HFile.getFormatVersion(conf) >= HFile.MIN_FORMAT_VERSION_WITH_TAGS);
}

代码示例来源：origin: apache/hbase

/**
 * Returns the factory to be used to create {@link HFile} writers
 */
public static final WriterFactory getWriterFactory(Configuration conf,
  CacheConfig cacheConf) {
 int version = getFormatVersion(conf);
 switch (version) {
 case 2:
  throw new IllegalArgumentException("This should never happen. " +
   "Did you change hfile.format.version to read v2? This version of the software writes v3" +
   " hfiles only (but it can read v2 files without having to update hfile.format.version " +
   "in hbase-site.xml)");
 case 3:
  return new HFile.WriterFactory(conf, cacheConf);
 default:
  throw new IllegalArgumentException("Cannot create writer for HFile " +
    "format version " + version);
 }
}

代码示例来源：origin: apache/hbase

protected HStore instantiateHStore(final ColumnFamilyDescriptor family) throws IOException {
 if (family.isMobEnabled()) {
  if (HFile.getFormatVersion(this.conf) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
   throw new IOException("A minimum HFile version of "
     + HFile.MIN_FORMAT_VERSION_WITH_TAGS
     + " is required for MOB feature. Consider setting " + HFile.FORMAT_VERSION_KEY
     + " accordingly.");
  }
  return new HMobStore(this, family, this.conf);
 }
 return new HStore(this, family, this.conf);
}

代码示例来源：origin: apache/hbase

@Override
public void start(CoprocessorEnvironment env) throws IOException {
 this.conf = env.getConfiguration();
 authorizationEnabled = AccessChecker.isAuthorizationSupported(conf);
 if (!authorizationEnabled) {
  LOG.warn("The VisibilityController has been loaded with authorization checks disabled.");
 }
 if (HFile.getFormatVersion(conf) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
  throw new RuntimeException("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS
   + " is required to persist visibility labels. Consider setting " + HFile.FORMAT_VERSION_KEY
   + " accordingly.");
 }
 // Do not create for master CPs
 if (!(env instanceof MasterCoprocessorEnvironment)) {
  visibilityLabelService = VisibilityLabelServiceManager.getInstance()
    .getVisibilityLabelService(this.conf);
 }
}

代码示例来源：origin: apache/hbase

/**
  * Create HStore instance.
  * @return If Mob is enabled, return HMobStore, otherwise return HStoreForTesting.
  */
 @Override
 protected HStore instantiateHStore(final ColumnFamilyDescriptor family) throws IOException {
  if (family.isMobEnabled()) {
   if (HFile.getFormatVersion(this.conf) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
    throw new IOException("A minimum HFile version of "
      + HFile.MIN_FORMAT_VERSION_WITH_TAGS
      + " is required for MOB feature. Consider setting " + HFile.FORMAT_VERSION_KEY
      + " accordingly.");
   }
   return new HMobStore(this, family, this.conf);
  }
  return new HStoreForTesting(this, family, this.conf);
 }
}

代码示例来源：origin: apache/hbase

AccessControlConstants.DEFAULT_EXEC_PERMISSION_CHECKS);
cellFeaturesEnabled = (HFile.getFormatVersion(conf) >= HFile.MIN_FORMAT_VERSION_WITH_TAGS);
if (!cellFeaturesEnabled) {
 LOG.info("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS

代码示例来源：origin: harbby/presto-connectors

public static boolean isCellAuthorizationSupported(Configuration conf) {
 return isAuthorizationSupported(conf) &&
   (HFile.getFormatVersion(conf) >= HFile.MIN_FORMAT_VERSION_WITH_TAGS);
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Returns the factory to be used to create {@link HFile} writers
 */
public static final WriterFactory getWriterFactory(Configuration conf,
  CacheConfig cacheConf) {
 int version = getFormatVersion(conf);
 switch (version) {
 case 2:
  return new HFileWriterV2.WriterFactoryV2(conf, cacheConf);
 case 3:
  return new HFileWriterV3.WriterFactoryV3(conf, cacheConf);
 default:
  throw new IllegalArgumentException("Cannot create writer for HFile " +
    "format version " + version);
 }
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Returns the factory to be used to create {@link HFile} writers
 */
public static final WriterFactory getWriterFactory(Configuration conf,
  CacheConfig cacheConf) {
 SchemaMetrics.configureGlobally(conf);
 int version = getFormatVersion(conf);
 switch (version) {
 case 1:
  return new HFileWriterV1.WriterFactoryV1(conf, cacheConf);
 case 2:
  return new HFileWriterV2.WriterFactoryV2(conf, cacheConf);
 default:
  throw new IllegalArgumentException("Cannot create writer for HFile " +
    "format version " + version);
 }
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void start(CoprocessorEnvironment env) throws IOException {
 this.conf = env.getConfiguration();
 authorizationEnabled = isAuthorizationSupported(conf);
 if (!authorizationEnabled) {
  LOG.warn("The VisibilityController has been loaded with authorization checks disabled.");
 }
 if (HFile.getFormatVersion(conf) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
  throw new RuntimeException("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS
   + " is required to persist visibility labels. Consider setting " + HFile.FORMAT_VERSION_KEY
   + " accordingly.");
 }
 if (env instanceof RegionServerCoprocessorEnvironment) {
  throw new RuntimeException("Visibility controller should not be configured as "
    + "'hbase.coprocessor.regionserver.classes'.");
 }
 // Do not create for master CPs
 if (!(env instanceof MasterCoprocessorEnvironment)) {
  visibilityLabelService = VisibilityLabelServiceManager.getInstance()
    .getVisibilityLabelService(this.conf);
 }
}

代码示例来源：origin: co.cask.hbase/hbase

if (HFile.getFormatVersion(conf) > HFile.MIN_FORMAT_VERSION) {

代码示例来源：origin: org.apache.hbase/hbase-server

/**
  * Create HStore instance.
  * @return If Mob is enabled, return HMobStore, otherwise return HStoreForTesting.
  */
 @Override
 protected HStore instantiateHStore(final ColumnFamilyDescriptor family) throws IOException {
  if (family.isMobEnabled()) {
   if (HFile.getFormatVersion(this.conf) < HFile.MIN_FORMAT_VERSION_WITH_TAGS) {
    throw new IOException("A minimum HFile version of "
      + HFile.MIN_FORMAT_VERSION_WITH_TAGS
      + " is required for MOB feature. Consider setting " + HFile.FORMAT_VERSION_KEY
      + " accordingly.");
   }
   return new HMobStore(this, family, this.conf);
  }
  return new HStoreForTesting(this, family, this.conf);
 }
}

代码示例来源：origin: co.cask.hbase/hbase

if (HFile.getFormatVersion(conf) > HFile.MIN_FORMAT_VERSION) {
 int maxFold = getMaxFold(conf);

代码示例来源：origin: harbby/presto-connectors

AccessControlConstants.DEFAULT_EXEC_PERMISSION_CHECKS);
cellFeaturesEnabled = (HFile.getFormatVersion(conf) >= HFile.MIN_FORMAT_VERSION_WITH_TAGS);
if (!cellFeaturesEnabled) {
 LOG.info("A minimum HFile version of " + HFile.MIN_FORMAT_VERSION_WITH_TAGS

内容来源于网络，如有侵权，请联系作者删除！

HFile

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com