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

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

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

HStore.determineTTLFromFamily介绍

暂无

代码示例

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

/**
 * Creates a store scanner.
 * @param filesToCompact The files to be compacted.
 * @param scanType The scan type.
 * @return The store scanner.
 * @throws IOException if IO failure is encountered
 */
private StoreScanner createScanner(List<HStoreFile> filesToCompact, ScanType scanType)
  throws IOException {
 List<StoreFileScanner> scanners = StoreFileScanner.getScannersForStoreFiles(filesToCompact,
  false, true, false, false, HConstants.LATEST_TIMESTAMP);
 long ttl = HStore.determineTTLFromFamily(column);
 ScanInfo scanInfo = new ScanInfo(conf, column, ttl, 0, CellComparator.getInstance());
 return new StoreScanner(scanInfo, scanType, scanners);
}

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

/**
 * Gets the number of del cell in the del files
 * @param paths the del file paths
 * @return the cell size
 */
private int countDelCellsInDelFiles(List<Path> paths) throws IOException {
 List<HStoreFile> sfs = new ArrayList<>();
 int size = 0;
 for (Path path : paths) {
  HStoreFile sf = new HStoreFile(fs, path, conf, cacheConf, BloomType.NONE, true);
  sfs.add(sf);
 }
 List<KeyValueScanner> scanners = new ArrayList<>(StoreFileScanner.getScannersForStoreFiles(sfs,
  false, true, false, false, HConstants.LATEST_TIMESTAMP));
 long timeToPurgeDeletes = Math.max(conf.getLong("hbase.hstore.time.to.purge.deletes", 0), 0);
 long ttl = HStore.determineTTLFromFamily(hcd);
 ScanInfo scanInfo = new ScanInfo(conf, hcd, ttl, timeToPurgeDeletes, CellComparatorImpl.COMPARATOR);
 StoreScanner scanner = new StoreScanner(scanInfo, ScanType.COMPACT_RETAIN_DELETES, scanners);
 List<Cell> results = new ArrayList<>();
 boolean hasMore = true;
 while (hasMore) {
  hasMore = scanner.next(results);
  size += results.size();
  results.clear();
 }
 scanner.close();
 return size;
}

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

LOG.trace("Time to purge deletes set to {}ms in store {}", timeToPurgeDeletes, this);
long ttl = determineTTLFromFamily(family);

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

false, false, HConstants.LATEST_TIMESTAMP);
long timeToPurgeDeletes = Math.max(conf.getLong("hbase.hstore.time.to.purge.deletes", 0), 0);
long ttl = HStore.determineTTLFromFamily(hcd);
ScanInfo scanInfo = new ScanInfo(copyOfConf, hcd, ttl, timeToPurgeDeletes,
 CellComparatorImpl.COMPARATOR);

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

/**
 * Gets the number of del cell in the del files
 * @param paths the del file paths
 * @return the cell size
 */
private int countDelCellsInDelFiles(List<Path> paths) throws IOException {
 List<HStoreFile> sfs = new ArrayList<>();
 int size = 0;
 for (Path path : paths) {
  HStoreFile sf = new HStoreFile(fs, path, conf, cacheConf, BloomType.NONE, true);
  sfs.add(sf);
 }
 List<KeyValueScanner> scanners = new ArrayList<>(StoreFileScanner.getScannersForStoreFiles(sfs,
  false, true, false, false, HConstants.LATEST_TIMESTAMP));
 long timeToPurgeDeletes = Math.max(conf.getLong("hbase.hstore.time.to.purge.deletes", 0), 0);
 long ttl = HStore.determineTTLFromFamily(hcd);
 ScanInfo scanInfo = new ScanInfo(conf, hcd, ttl, timeToPurgeDeletes, CellComparatorImpl.COMPARATOR);
 StoreScanner scanner = new StoreScanner(scanInfo, ScanType.COMPACT_RETAIN_DELETES, scanners);
 List<Cell> results = new ArrayList<>();
 boolean hasMore = true;
 while (hasMore) {
  hasMore = scanner.next(results);
  size += results.size();
  results.clear();
 }
 scanner.close();
 return size;
}

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

false, false, HConstants.LATEST_TIMESTAMP);
long timeToPurgeDeletes = Math.max(conf.getLong("hbase.hstore.time.to.purge.deletes", 0), 0);
long ttl = HStore.determineTTLFromFamily(hcd);
ScanInfo scanInfo = new ScanInfo(copyOfConf, hcd, ttl, timeToPurgeDeletes,
 CellComparatorImpl.COMPARATOR);

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

"ms in store " + this);
long ttl = determineTTLFromFamily(family);

相关文章

HStore类方法