org.apache.hadoop.hbase.client.Delete#setDurability ( )源码实例Demo

public Delete buildRowDeleteMutation(byte[] indexRowKey, DeleteType deleteType, long ts) {
    byte[] emptyCF = emptyKeyValueCFPtr.copyBytesIfNecessary();
    Delete delete = new Delete(indexRowKey);

    for (ColumnReference ref : getCoveredColumns()) {
        ColumnReference indexColumn = coveredColumnsMap.get(ref);
        // If table delete was single version, then index delete should be as well
        if (deleteType == DeleteType.SINGLE_VERSION) {
            delete.addFamilyVersion(indexColumn.getFamily(), ts);
        } else {
            delete.addFamily(indexColumn.getFamily(), ts);
        }
    }
    if (deleteType == DeleteType.SINGLE_VERSION) {
        delete.addFamilyVersion(emptyCF, ts);
    } else {
        delete.addFamily(emptyCF, ts);
    }
    delete.setDurability(!indexWALDisabled ? Durability.USE_DEFAULT : Durability.SKIP_WAL);
    return delete;
}
 

private void newMutations() {
     Mutation put = this.hasOnDupKey ? new Increment(this.key) : new Put(this.key);
     Delete delete = new Delete(this.key);
     if (isWALDisabled()) {
         put.setDurability(Durability.SKIP_WAL);
         delete.setDurability(Durability.SKIP_WAL);
     }
     this.setValues = put;
     this.unsetValues = delete;
}