You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2018/05/05 00:53:23 UTC
[4/7] hbase git commit: HBASE-20517 Fix PerformanceEvaluation
'column' parameter
HBASE-20517 Fix PerformanceEvaluation 'column' parameter
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fd24083e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fd24083e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fd24083e
Branch: refs/heads/branch-1
Commit: fd24083e26a2d49e30009bb2b3b26f0095f99c77
Parents: e793e7c
Author: Andrew Purtell <ap...@apache.org>
Authored: Thu May 3 16:27:23 2018 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Fri May 4 17:24:38 2018 -0700
----------------------------------------------------------------------
.../hadoop/hbase/PerformanceEvaluation.java | 31 +++++++++++++++-----
1 file changed, 24 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/fd24083e/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
index 85d3613..60d6cb6 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
@@ -135,7 +135,6 @@ public class PerformanceEvaluation extends Configured implements Tool {
public static final String TABLE_NAME = "TestTable";
public static final byte[] FAMILY_NAME = Bytes.toBytes("info");
public static final byte [] COLUMN_ZERO = Bytes.toBytes("" + 0);
- public static final byte [] QUALIFIER_NAME = COLUMN_ZERO;
public static final int DEFAULT_VALUE_LENGTH = 1000;
public static final int ROW_LENGTH = 26;
@@ -1207,7 +1206,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
scan.setCaching(opts.caching);
FilterList list = new FilterList();
if (opts.addColumns) {
- scan.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ scan.addColumn(FAMILY_NAME, qualifier);
+ }
} else {
scan.addFamily(FAMILY_NAME);
}
@@ -1245,7 +1247,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
scan.setFilter(new FilterAllFilter());
}
if (opts.addColumns) {
- scan.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ scan.addColumn(FAMILY_NAME, qualifier);
+ }
} else {
scan.addFamily(FAMILY_NAME);
}
@@ -1345,7 +1350,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
Get get = new Get(getRandomRow(this.rand, opts.totalRows));
if (opts.addColumns) {
- get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ get.addColumn(FAMILY_NAME, qualifier);
+ }
} else {
get.addFamily(FAMILY_NAME);
}
@@ -1440,7 +1448,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
Scan scan = new Scan(format(opts.startRow));
scan.setCaching(opts.caching);
if (opts.addColumns) {
- scan.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ scan.addColumn(FAMILY_NAME, qualifier);
+ }
} else {
scan.addFamily(FAMILY_NAME);
}
@@ -1573,7 +1584,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
void testRow(final int i) throws IOException {
Get get = new Get(format(i));
if (opts.addColumns) {
- get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ get.addColumn(FAMILY_NAME, qualifier);
+ }
}
if (opts.filterAll) {
get.setFilter(new FilterAllFilter());
@@ -1653,7 +1667,10 @@ public class PerformanceEvaluation extends Configured implements Tool {
Scan scan = new Scan();
scan.setCaching(opts.caching);
if (opts.addColumns) {
- scan.addColumn(FAMILY_NAME, QUALIFIER_NAME);
+ for (int column = 0; column < opts.columns; column++) {
+ byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);
+ scan.addColumn(FAMILY_NAME, qualifier);
+ }
} else {
scan.addFamily(FAMILY_NAME);
}