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

x33g5p2x  于2022-01-30 转载在 其他  
字(12.9k)|赞(0)|评价(0)|浏览(195)

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

Store.getScanInfo介绍

暂无

代码示例

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, Collections.singletonList(memstoreScanner),
             ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(), HConstants.OLDEST_TIMESTAMP);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                       List<? extends KeyValueScanner> scanners, ScanType scanType,
                       long earliestPutTs, InternalScanner s,
                       CompactionRequest request) throws IOException {
 LOG.info("preCompact, filter using PayloadDataFilter");
 Scan scan = new Scan();
 scan.setFilter(new PayloadDataFilter(c.getEnvironment(), System.currentTimeMillis(), prefixLength,
                    topicMetadataCache));
 return new StoreScanner(store, store.getScanInfo(), scan, scanners, scanType, store.getSmallestReadPoint(),
             earliestPutTs);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using MessageDataFilter");
 TransactionVisibilityState txVisibilityState = txStateCache.getLatestState();
 Scan scan = new Scan();
 scan.setFilter(new MessageDataFilter(c.getEnvironment(), System.currentTimeMillis(),
                    prefixLength, topicMetadataCache, txVisibilityState));
 return new LoggingInternalScanner("MessageDataFilter", "preFlush",
                  new StoreScanner(store, store.getScanInfo(), scan,
                           Collections.singletonList(memstoreScanner),
                           ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(),
                           HConstants.OLDEST_TIMESTAMP), txVisibilityState);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using MessageDataFilter");
 TransactionVisibilityState txVisibilityState = txStateCache.getLatestState();
 Scan scan = new Scan();
 scan.setFilter(new MessageDataFilter(c.getEnvironment(), System.currentTimeMillis(),
                    prefixLength, topicMetadataCache, txVisibilityState));
 return new LoggingInternalScanner("MessageDataFilter", "preFlush",
                  new StoreScanner(store, store.getScanInfo(), scan,
                           Collections.singletonList(memstoreScanner),
                           ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(),
                           HConstants.OLDEST_TIMESTAMP), txVisibilityState);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using MessageDataFilter");
 TransactionVisibilityState txVisibilityState = txStateCache.getLatestState();
 Scan scan = new Scan();
 scan.setFilter(new MessageDataFilter(c.getEnvironment(), System.currentTimeMillis(),
                    prefixLength, topicMetadataCache, txVisibilityState));
 return new LoggingInternalScanner("MessageDataFilter", "preFlush",
                  new StoreScanner(store, store.getScanInfo(), scan,
                           Collections.singletonList(memstoreScanner),
                           ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(),
                           HConstants.OLDEST_TIMESTAMP), txVisibilityState);
}

代码示例来源：origin: caskdata/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using MessageDataFilter");
 TransactionVisibilityState txVisibilityState = txStateCache.getLatestState();
 Scan scan = new Scan();
 scan.setFilter(new MessageDataFilter(c.getEnvironment(), System.currentTimeMillis(),
                    prefixLength, topicMetadataCache, txVisibilityState));
 return new LoggingInternalScanner("MessageDataFilter", "preFlush",
                  new StoreScanner(store, store.getScanInfo(), scan,
                           Collections.singletonList(memstoreScanner),
                           ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(),
                           HConstants.OLDEST_TIMESTAMP), txVisibilityState);
}

代码示例来源：origin: cdapio/cdap

@Override
public InternalScanner preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
                      KeyValueScanner memstoreScanner, InternalScanner s) throws IOException {
 LOG.info("preFlush, filter using MessageDataFilter");
 TransactionVisibilityState txVisibilityState = txStateCache.getLatestState();
 Scan scan = new Scan();
 scan.setFilter(new MessageDataFilter(c.getEnvironment(), System.currentTimeMillis(),
                    prefixLength, topicMetadataCache, txVisibilityState));
 return new LoggingInternalScanner("MessageDataFilter", "preFlush",
                  new StoreScanner(store, store.getScanInfo(), scan,
                           Collections.singletonList(memstoreScanner),
                           ScanType.COMPACT_DROP_DELETES, store.getSmallestReadPoint(),
                           HConstants.OLDEST_TIMESTAMP), txVisibilityState);
}

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

protected ScanInfo getScanInfo(Store store, RegionCoprocessorEnvironment e) {
 byte[] data = ((ZKWatcher)e.getSharedData().get(zkkey)).getData();
 if (data == null) {
  return null;
 }
 ScanInfo oldSI = store.getScanInfo();
 if (oldSI.getTtl() == Long.MAX_VALUE) {
  return null;
 }
 long ttl =  Math.max(EnvironmentEdgeManager.currentTimeMillis() - Bytes.toLong(data), oldSI.getTtl());    
 return new ScanInfo(store.getFamily(), ttl,
   oldSI.getTimeToPurgeDeletes(), oldSI.getComparator());
}

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

store

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Store类方法

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