You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafodion.apache.org by se...@apache.org on 2015/11/13 03:45:56 UTC
[2/7] incubator-trafodion git commit: Update
SingleVersionDeleteNotSupported.java
Update SingleVersionDeleteNotSupported.java
use cell.getTypeByte instead of constructing a new object kv
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/bdc8c10e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/bdc8c10e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/bdc8c10e
Branch: refs/heads/master
Commit: bdc8c10ea5e78cb8f81fc4935d1a8fdbef8c9a6a
Parents: dd2ea96
Author: mashengchen <ma...@gmail.com>
Authored: Thu Nov 12 11:26:05 2015 +0800
Committer: mashengchen <ma...@gmail.com>
Committed: Thu Nov 12 11:26:05 2015 +0800
----------------------------------------------------------------------
.../transactional/SingleVersionDeleteNotSupported.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/bdc8c10e/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java
----------------------------------------------------------------------
diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java
index 7d1157e..6cd6743 100755
--- a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java
+++ b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java
@@ -57,8 +57,7 @@ public class SingleVersionDeleteNotSupported extends DoNotRetryIOException {
Collection<List<Cell>> values = delete.getFamilyCellMap().values();
for (List<Cell> value : values) {
for (Cell cell : value) {
- KeyValue kv = new KeyValue(cell);
- if (Type.Delete.getCode() == kv.getTypeByte()) {
+ if (cell.getTypeByte() == Type.Delete.getCode()) {
throw new SingleVersionDeleteNotSupported();
}
}