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

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

本文整理了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());
}

相关文章