import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
/**
 * Adds all the attributes into the Operation object
 */
private static void addAttributes(OperationWithAttributes op,
                                  Map<ByteBuffer, ByteBuffer> attributes) {
  if (attributes == null || attributes.size() == 0) {
    return;
  }
  for (Map.Entry<ByteBuffer, ByteBuffer> entry : attributes.entrySet()) {
    String name = Bytes.toStringBinary(getBytes(entry.getKey()));
    byte[] value =  getBytes(entry.getValue());
    op.setAttribute(name, value);
  }
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
/**
 * Adds all the attributes into the Operation object
 */
private static void addAttributes(OperationWithAttributes op,
  Map<ByteBuffer, ByteBuffer> attributes) {
  if (attributes == null || attributes.size() == 0) {
    return;
  }
  for (Map.Entry<ByteBuffer, ByteBuffer> entry : attributes.entrySet()) {
    String name = Bytes.toStringBinary(getBytes(entry.getKey()));
    byte[] value =  getBytes(entry.getValue());
    op.setAttribute(name, value);
  }
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
private Transaction getFromOperation(OperationWithAttributes op) throws IOException {
  byte[] encoded = op.getAttribute(TxConstants.TX_OPERATION_ATTRIBUTE_KEY);
  if (encoded == null) {
    // to support old clients
    encoded = op.getAttribute(TxConstants.OLD_TX_OPERATION_ATTRIBUTE_KEY);
  }
  if (encoded != null) {
    return txCodec.decode(encoded);
  }
  return null;
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
/**
 * Make sure that the transaction is within the max valid transaction lifetime.
 *
 * @param env {@link RegionCoprocessorEnvironment} of the Region to which the coprocessor is associated
 * @param op {@link OperationWithAttributes} HBase operation to access its attributes if required
 * @param tx {@link Transaction} supplied by the
 * @throws DoNotRetryIOException thrown if the transaction is older than the max lifetime of a transaction
 *         IOException throw if the value of max lifetime of transaction is unavailable
 */
protected void ensureValidTxLifetime(RegionCoprocessorEnvironment env,
                                     @SuppressWarnings("unused") OperationWithAttributes op,
                                     @Nullable Transaction tx) throws IOException {
  if (tx == null) {
    return;
  }

  boolean validLifetime =
    (TxUtils.getTimestamp(tx.getTransactionId()) + txMaxLifetimeMillis) > System.currentTimeMillis();
  if (!validLifetime) {
    throw new DoNotRetryIOException(String.format("Transaction %s has exceeded max lifetime %s ms",
                                                  tx.getTransactionId(), txMaxLifetimeMillis));
  }
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
/**
 * Adds all the attributes into the Operation object
 */
private static void addAttributes(OperationWithAttributes op,
                                  Map<ByteBuffer, ByteBuffer> attributes) {
  if (attributes == null || attributes.isEmpty()) {
    return;
  }
  for (Map.Entry<ByteBuffer, ByteBuffer> entry : attributes.entrySet()) {
    String name = Bytes.toStringBinary(getBytes(entry.getKey()));
    byte[] value =  getBytes(entry.getValue());
    op.setAttribute(name, value);
  }
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
/**
 * Adds all the attributes into the Operation object
 */
private static void addAttributes(OperationWithAttributes op,
  Map<ByteBuffer, ByteBuffer> attributes) {
  if (attributes == null || attributes.isEmpty()) {
    return;
  }
  for (Map.Entry<ByteBuffer, ByteBuffer> entry : attributes.entrySet()) {
    String name = Bytes.toStringBinary(getBytes(entry.getKey()));
    byte[] value =  getBytes(entry.getValue());
    op.setAttribute(name, value);
  }
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
private boolean isRollbackOperation(OperationWithAttributes op) throws IOException {
  return op.getAttribute(TxConstants.TX_ROLLBACK_ATTRIBUTE_KEY) != null ||
    // to support old clients
    op.getAttribute(TxConstants.OLD_TX_ROLLBACK_ATTRIBUTE_KEY) != null;
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
public void addToOperation(OperationWithAttributes op, Transaction tx) throws IOException {
  op.setAttribute(TxConstants.TX_OPERATION_ATTRIBUTE_KEY, txCodec.encode(tx));
}
 

import org.apache.hadoop.hbase.client.OperationWithAttributes; //导入依赖的package包/类
@Override
public void addToOperation(OperationWithAttributes op, Transaction tx) throws IOException {
  op.setAttribute(TxConstants.OLD_TX_OPERATION_ATTRIBUTE_KEY, txCodec.encode(tx));
}