tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [416:431]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected InternalScanner createStoreScanner(RegionCoprocessorEnvironment env, String action,
      TransactionVisibilityState snapshot, InternalScanner scanner,
      ScanType type) throws IOException {
    if (snapshot == null) {
      if (LOG.isDebugEnabled()) {
        LOG.debug("Region " + env.getRegion().getRegionInfo().getRegionNameAsString()
            + ", no current transaction state found, defaulting to normal " + action + " scanner");
      }
      return null;
    }
    // construct a dummy transaction from the latest snapshot
    Transaction dummyTx = TxUtils.createDummyTransaction(snapshot);
    return new FilteredInternalScanner(scanner,
        new IncludeInProgressFilter(dummyTx.getVisibilityUpperBound(), snapshot.getInvalid(),
            getTransactionFilter(dummyTx, type, null)));
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.3/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [416:431]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected InternalScanner createStoreScanner(RegionCoprocessorEnvironment env, String action,
      TransactionVisibilityState snapshot, InternalScanner scanner,
      ScanType type) throws IOException {
    if (snapshot == null) {
      if (LOG.isDebugEnabled()) {
        LOG.debug("Region " + env.getRegion().getRegionInfo().getRegionNameAsString()
            + ", no current transaction state found, defaulting to normal " + action + " scanner");
      }
      return null;
    }
    // construct a dummy transaction from the latest snapshot
    Transaction dummyTx = TxUtils.createDummyTransaction(snapshot);
    return new FilteredInternalScanner(scanner,
        new IncludeInProgressFilter(dummyTx.getVisibilityUpperBound(), snapshot.getInvalid(),
            getTransactionFilter(dummyTx, type, null)));
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.4/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [416:431]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected InternalScanner createStoreScanner(RegionCoprocessorEnvironment env, String action,
      TransactionVisibilityState snapshot, InternalScanner scanner,
      ScanType type) throws IOException {
    if (snapshot == null) {
      if (LOG.isDebugEnabled()) {
        LOG.debug("Region " + env.getRegion().getRegionInfo().getRegionNameAsString()
            + ", no current transaction state found, defaulting to normal " + action + " scanner");
      }
      return null;
    }
    // construct a dummy transaction from the latest snapshot
    Transaction dummyTx = TxUtils.createDummyTransaction(snapshot);
    return new FilteredInternalScanner(scanner,
        new IncludeInProgressFilter(dummyTx.getVisibilityUpperBound(), snapshot.getInvalid(),
            getTransactionFilter(dummyTx, type, null)));
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -