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

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

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

HStore.getBytesPerChecksum介绍

[英]Returns the configured bytesPerChecksum value.
[中]返回配置的bytesPerChecksum值。

代码示例

代码示例来源: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.bytesPerChecksum = getBytesPerChecksum(conf);
flushRetriesNumber = conf.getInt(
  "hbase.hstore.flush.retries.number", DEFAULT_FLUSH_RETRIES_NUMBER);

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

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

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

.withCompressTags(family.isCompressTags())
.withChecksumType(HStore.getChecksumType(conf))
.withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
.withBlockSize(family.getBlocksize())
.withHBaseCheckSum(true)

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

.withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);
contextBuilder.withDataBlockEncoding(encoding);

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

.withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);
contextBuilder.withDataBlockEncoding(encoding);

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

.withCompression(compression)
             .withChecksumType(HStore.getChecksumType(conf))
             .withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
             .withBlockSize(blockSize);
contextBuilder.withDataBlockEncoding(encoding);

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

this.bytesPerChecksum = getBytesPerChecksum(conf);
flushRetriesNumber = conf.getInt(
  "hbase.hstore.flush.retries.number", DEFAULT_FLUSH_RETRIES_NUMBER);

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

.withCompression(compression)
.withChecksumType(HStore.getChecksumType(conf))
.withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
.withBlockSize(blocksize)
.withDataBlockEncoding(familyDescriptor.getDataBlockEncoding())

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

.withCompressTags(family.isCompressTags())
.withChecksumType(HStore.getChecksumType(conf))
.withBytesPerCheckSum(HStore.getBytesPerChecksum(conf))
.withBlockSize(family.getBlocksize())
.withHBaseCheckSum(true)

相关文章

HStore类方法