tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [131:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void start(CoprocessorEnvironment e) throws IOException {
    if (e instanceof RegionCoprocessorEnvironment) {
      RegionCoprocessorEnvironment env = (RegionCoprocessorEnvironment) e;
      this.cacheSupplier = getTransactionStateCacheSupplier(env);
      this.cache = cacheSupplier.get();

      TableDescriptor tableDesc = env.getRegion().getTableDescriptor();
      for (ColumnFamilyDescriptor columnDesc : tableDesc.getColumnFamilies()) {
        byte[] columnTTL = columnDesc.getValue(Bytes.toBytes(TxConstants.PROPERTY_TTL));
        long ttl = 0;
        if (columnTTL != null) {
          try {
            ttl = Long.parseLong(Bytes.toString(columnTTL));
            LOG.info("Family " + columnDesc.getNameAsString() + " has TTL of " + ttl);
          } catch (NumberFormatException nfe) {
            LOG.warn("Invalid TTL value configured for column family "
                + columnDesc.getNameAsString() + ", value = " + Bytes.toString(columnTTL));
          }
        }
        ttlByFamily.put(columnDesc.getName(), ttl);
      }

      this.allowEmptyValues = getAllowEmptyValues(env, tableDesc);
      this.txMaxLifetimeMillis = getTxMaxLifetimeMillis(env);
      this.readNonTxnData = Boolean.valueOf(tableDesc.getValue(TxConstants.READ_NON_TX_DATA));
      if (readNonTxnData) {
        LOG.info("Reading pre-existing data enabled for table "
            + tableDesc.getTableName().getNameAsString());
      }
      initializePruneState(env);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.3/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [131:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void start(CoprocessorEnvironment e) throws IOException {
    if (e instanceof RegionCoprocessorEnvironment) {
      RegionCoprocessorEnvironment env = (RegionCoprocessorEnvironment) e;
      this.cacheSupplier = getTransactionStateCacheSupplier(env);
      this.cache = cacheSupplier.get();

      TableDescriptor tableDesc = env.getRegion().getTableDescriptor();
      for (ColumnFamilyDescriptor columnDesc : tableDesc.getColumnFamilies()) {
        byte[] columnTTL = columnDesc.getValue(Bytes.toBytes(TxConstants.PROPERTY_TTL));
        long ttl = 0;
        if (columnTTL != null) {
          try {
            ttl = Long.parseLong(Bytes.toString(columnTTL));
            LOG.info("Family " + columnDesc.getNameAsString() + " has TTL of " + ttl);
          } catch (NumberFormatException nfe) {
            LOG.warn("Invalid TTL value configured for column family "
                + columnDesc.getNameAsString() + ", value = " + Bytes.toString(columnTTL));
          }
        }
        ttlByFamily.put(columnDesc.getName(), ttl);
      }

      this.allowEmptyValues = getAllowEmptyValues(env, tableDesc);
      this.txMaxLifetimeMillis = getTxMaxLifetimeMillis(env);
      this.readNonTxnData = Boolean.valueOf(tableDesc.getValue(TxConstants.READ_NON_TX_DATA));
      if (readNonTxnData) {
        LOG.info("Reading pre-existing data enabled for table "
            + tableDesc.getTableName().getNameAsString());
      }
      initializePruneState(env);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.4/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [131:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void start(CoprocessorEnvironment e) throws IOException {
    if (e instanceof RegionCoprocessorEnvironment) {
      RegionCoprocessorEnvironment env = (RegionCoprocessorEnvironment) e;
      this.cacheSupplier = getTransactionStateCacheSupplier(env);
      this.cache = cacheSupplier.get();

      TableDescriptor tableDesc = env.getRegion().getTableDescriptor();
      for (ColumnFamilyDescriptor columnDesc : tableDesc.getColumnFamilies()) {
        byte[] columnTTL = columnDesc.getValue(Bytes.toBytes(TxConstants.PROPERTY_TTL));
        long ttl = 0;
        if (columnTTL != null) {
          try {
            ttl = Long.parseLong(Bytes.toString(columnTTL));
            LOG.info("Family " + columnDesc.getNameAsString() + " has TTL of " + ttl);
          } catch (NumberFormatException nfe) {
            LOG.warn("Invalid TTL value configured for column family "
                + columnDesc.getNameAsString() + ", value = " + Bytes.toString(columnTTL));
          }
        }
        ttlByFamily.put(columnDesc.getName(), ttl);
      }

      this.allowEmptyValues = getAllowEmptyValues(env, tableDesc);
      this.txMaxLifetimeMillis = getTxMaxLifetimeMillis(env);
      this.readNonTxnData = Boolean.valueOf(tableDesc.getValue(TxConstants.READ_NON_TX_DATA));
      if (readNonTxnData) {
        LOG.info("Reading pre-existing data enabled for table "
            + tableDesc.getTableName().getNameAsString());
      }
      initializePruneState(env);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -