tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [384:402]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public InternalScanner preCompact(
      org.apache.hadoop.hbase.coprocessor.ObserverContext<RegionCoprocessorEnvironment> c,
      Store store, InternalScanner scanner, ScanType scanType,
      org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
      CompactionRequest request) throws IOException {
    // Get the latest tx snapshot state for the compaction
    TransactionVisibilityState snapshot = cache.getLatestState();
    // Record tx state before the compaction
    if (compactionState != null) {
      compactionState.record(request, snapshot);
    }
    // Also make sure to use the same snapshot for the compaction
    InternalScanner s =
        createStoreScanner(c.getEnvironment(), "compaction", snapshot, scanner, scanType);
    if (s != null) {
      return s;
    }
    return scanner;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.3/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [384:402]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public InternalScanner preCompact(
      org.apache.hadoop.hbase.coprocessor.ObserverContext<RegionCoprocessorEnvironment> c,
      Store store, InternalScanner scanner, ScanType scanType,
      org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
      CompactionRequest request) throws IOException {
    // Get the latest tx snapshot state for the compaction
    TransactionVisibilityState snapshot = cache.getLatestState();
    // Record tx state before the compaction
    if (compactionState != null) {
      compactionState.record(request, snapshot);
    }
    // Also make sure to use the same snapshot for the compaction
    InternalScanner s =
        createStoreScanner(c.getEnvironment(), "compaction", snapshot, scanner, scanType);
    if (s != null) {
      return s;
    }
    return scanner;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.4/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [384:402]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public InternalScanner preCompact(
      org.apache.hadoop.hbase.coprocessor.ObserverContext<RegionCoprocessorEnvironment> c,
      Store store, InternalScanner scanner, ScanType scanType,
      org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
      CompactionRequest request) throws IOException {
    // Get the latest tx snapshot state for the compaction
    TransactionVisibilityState snapshot = cache.getLatestState();
    // Record tx state before the compaction
    if (compactionState != null) {
      compactionState.record(request, snapshot);
    }
    // Also make sure to use the same snapshot for the compaction
    InternalScanner s =
        createStoreScanner(c.getEnvironment(), "compaction", snapshot, scanner, scanType);
    if (s != null) {
      return s;
    }
    return scanner;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -