org.apache.hadoop.hbase.regionserver.HStore.getChecksumType()方法的使用及代码示例

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

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

HStore.getChecksumType介绍

[英]Returns the configured checksum algorithm.
[中]返回配置的校验和算法。

代码示例

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

/**
 * Creates a writer for the ref file in temp directory.
 * @param conf The current configuration.
 * @param fs The current file system.
 * @param family The descriptor of the current column family.
 * @param basePath The basic path for a temp directory.
 * @param maxKeyCount The key count.
 * @param cacheConfig The current cache config.
 * @param cryptoContext The encryption context.
 * @param isCompaction If the writer is used in compaction.
 * @return The writer for the mob file.
 * @throws IOException
 */
public static StoreFileWriter createRefFileWriter(Configuration conf, FileSystem fs,
 ColumnFamilyDescriptor family, Path basePath, long maxKeyCount, CacheConfig cacheConfig,
 Encryption.Context cryptoContext, boolean isCompaction)
 throws IOException {
 return createWriter(conf, fs, family,
  new Path(basePath, UUID.randomUUID().toString().replaceAll("-", "")), maxKeyCount,
  family.getCompactionCompressionType(), cacheConfig, cryptoContext,
  HStore.getChecksumType(conf), HStore.getBytesPerChecksum(conf), family.getBlocksize(),
  family.getBloomFilterType(), isCompaction);
}

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

/**
 * Creates a writer for the mob file in temp directory.
 * @param conf The current configuration.
 * @param fs The current file system.
 * @param family The descriptor of the current column family.
 * @param mobFileName The mob file name.
 * @param basePath The basic path for a temp directory.
 * @param maxKeyCount The key count.
 * @param compression The compression algorithm.
 * @param cacheConfig The current cache config.
 * @param cryptoContext The encryption context.
 * @param isCompaction If the writer is used in compaction.
 * @return The writer for the mob file.
 * @throws IOException
 */
public static StoreFileWriter createWriter(Configuration conf, FileSystem fs,
                      ColumnFamilyDescriptor family, MobFileName mobFileName, Path basePath, long maxKeyCount,
  Compression.Algorithm compression, CacheConfig cacheConfig, Encryption.Context cryptoContext,
  boolean isCompaction)
  throws IOException {
 return createWriter(conf, fs, family,
  new Path(basePath, mobFileName.getFileName()), maxKeyCount, compression, cacheConfig,
  cryptoContext, HStore.getChecksumType(conf), HStore.getBytesPerChecksum(conf),
  family.getBlocksize(), BloomType.NONE, isCompaction);
}

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

this.checksumType = getChecksumType(conf);

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

BloomType bloomFilterType = familyDescriptor.getBloomFilterType();
HFileContext hFileContext = new HFileContextBuilder().withCompression(compression)
  .withChecksumType(HStore.getChecksumType(conf))
  .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf)).withBlockSize(blocksize)
  .withDataBlockEncoding(familyDescriptor.getDataBlockEncoding()).withIncludesTags(true)

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

.withCompression(compression)
.withCompressTags(family.isCompressTags())
.withChecksumType(HStore.getChecksumType(conf))
.withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
.withBlockSize(family.getBlocksize())

代码示例来源:origin: apache/phoenix

HFileContextBuilder contextBuilder = new HFileContextBuilder()
             .withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);

代码示例来源:origin: org.apache.phoenix/phoenix-core

HFileContextBuilder contextBuilder = new HFileContextBuilder()
             .withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);

代码示例来源:origin: com.aliyun.phoenix/ali-phoenix-core

HFileContextBuilder contextBuilder = new HFileContextBuilder()
             .withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);

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

this.checksumType = getChecksumType(conf);

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

HFileContext hFileContext = new HFileContextBuilder()
              .withCompression(compression)
              .withChecksumType(HStore.getChecksumType(conf))
              .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
              .withBlockSize(blocksize)

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

.withCompression(compression)
.withCompressTags(family.isCompressTags())
.withChecksumType(HStore.getChecksumType(conf))
.withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
.withBlockSize(family.getBlocksize())

相关文章

HStore类方法