本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.getScanInfo()
方法的一些代码示例,展示了Store.getScanInfo()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.getScanInfo()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!