tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [494:520]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void initializePruneState(RegionCoprocessorEnvironment env) {
    Configuration conf = getConfiguration(env);
    if (conf != null) {
      pruneEnable =
          conf.getBoolean(TxConstants.TransactionPruning.PRUNE_ENABLE,
            TxConstants.TransactionPruning.DEFAULT_PRUNE_ENABLE);

      if (Boolean.TRUE.equals(pruneEnable)) {
        TableName pruneTable =
            TableName.valueOf(conf.get(TxConstants.TransactionPruning.PRUNE_STATE_TABLE,
              TxConstants.TransactionPruning.DEFAULT_PRUNE_STATE_TABLE));
        long pruneFlushInterval =
            TimeUnit.SECONDS
                .toMillis(conf.getLong(TxConstants.TransactionPruning.PRUNE_FLUSH_INTERVAL,
                  TxConstants.TransactionPruning.DEFAULT_PRUNE_FLUSH_INTERVAL));

        compactionState = new CompactionState(env, pruneTable, pruneFlushInterval);
        if (LOG.isDebugEnabled()) {
          LOG.debug(String.format(
            "Automatic invalid list pruning is enabled for table %s. Compaction state "
                + "will be recorded in table %s",
            env.getRegionInfo().getTable().getNameWithNamespaceInclAsString(),
            pruneTable.getNameWithNamespaceInclAsString()));
        }
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.3/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [494:520]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void initializePruneState(RegionCoprocessorEnvironment env) {
    Configuration conf = getConfiguration(env);
    if (conf != null) {
      pruneEnable =
          conf.getBoolean(TxConstants.TransactionPruning.PRUNE_ENABLE,
            TxConstants.TransactionPruning.DEFAULT_PRUNE_ENABLE);

      if (Boolean.TRUE.equals(pruneEnable)) {
        TableName pruneTable =
            TableName.valueOf(conf.get(TxConstants.TransactionPruning.PRUNE_STATE_TABLE,
              TxConstants.TransactionPruning.DEFAULT_PRUNE_STATE_TABLE));
        long pruneFlushInterval =
            TimeUnit.SECONDS
                .toMillis(conf.getLong(TxConstants.TransactionPruning.PRUNE_FLUSH_INTERVAL,
                  TxConstants.TransactionPruning.DEFAULT_PRUNE_FLUSH_INTERVAL));

        compactionState = new CompactionState(env, pruneTable, pruneFlushInterval);
        if (LOG.isDebugEnabled()) {
          LOG.debug(String.format(
            "Automatic invalid list pruning is enabled for table %s. Compaction state "
                + "will be recorded in table %s",
            env.getRegionInfo().getTable().getNameWithNamespaceInclAsString(),
            pruneTable.getNameWithNamespaceInclAsString()));
        }
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.4/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [494:520]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void initializePruneState(RegionCoprocessorEnvironment env) {
    Configuration conf = getConfiguration(env);
    if (conf != null) {
      pruneEnable =
          conf.getBoolean(TxConstants.TransactionPruning.PRUNE_ENABLE,
            TxConstants.TransactionPruning.DEFAULT_PRUNE_ENABLE);

      if (Boolean.TRUE.equals(pruneEnable)) {
        TableName pruneTable =
            TableName.valueOf(conf.get(TxConstants.TransactionPruning.PRUNE_STATE_TABLE,
              TxConstants.TransactionPruning.DEFAULT_PRUNE_STATE_TABLE));
        long pruneFlushInterval =
            TimeUnit.SECONDS
                .toMillis(conf.getLong(TxConstants.TransactionPruning.PRUNE_FLUSH_INTERVAL,
                  TxConstants.TransactionPruning.DEFAULT_PRUNE_FLUSH_INTERVAL));

        compactionState = new CompactionState(env, pruneTable, pruneFlushInterval);
        if (LOG.isDebugEnabled()) {
          LOG.debug(String.format(
            "Automatic invalid list pruning is enabled for table %s. Compaction state "
                + "will be recorded in table %s",
            env.getRegionInfo().getTable().getNameWithNamespaceInclAsString(),
            pruneTable.getNameWithNamespaceInclAsString()));
        }
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -