Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11585 PE: Allows warm-up

This commit is contained in:
Nicolas Liochon 2014-08-04 11:41:34 +02:00
parent 543c64d2e9
commit 4d005b70a0
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
View File

@ -567,6 +567,7 @@ public class PerformanceEvaluation extends Configured implements Tool {
int perClientRunRows = DEFAULT_ROWS_PER_GB;
int numClientThreads = 1;
int totalRows = DEFAULT_ROWS_PER_GB;
int measureAfter = 0;
float sampleRate = 1.0f;
double traceRate = 0.0;
String tableName = TABLE_NAME;
@ -631,6 +632,7 @@ public class PerformanceEvaluation extends Configured implements Tool {
this.valueSize = that.valueSize;
this.period = that.period;
this.randomSleep = that.randomSleep;
this.measureAfter = that.measureAfter;
}
public int getCycles() {
@ -888,6 +890,14 @@ public class PerformanceEvaluation extends Configured implements Tool {
public boolean isOneCon() {
return oneCon;
}
public int getMeasureAfter() {
return measureAfter;
}
public void setMeasureAfter(int measureAfter) {
this.measureAfter = measureAfter;
}
}
/*
@ -1048,9 +1058,11 @@ public class PerformanceEvaluation extends Configured implements Tool {
} finally {
scope.close();
}
latency.update((System.nanoTime() - startTime) / 1000);
if (status != null && i > 0 && (i % getReportingPeriod()) == 0) {
status.setStatus(generateStatus(opts.startRow, i, lastRow));
if ( (i - opts.startRow) > opts.measureAfter) {
latency.update((System.nanoTime() - startTime) / 1000);
if (status != null && i > 0 && (i % getReportingPeriod()) == 0) {
status.setStatus(generateStatus(opts.startRow, i, lastRow));
}
}
}
}
@ -1611,6 +1623,8 @@ public class PerformanceEvaluation extends Configured implements Tool {
+ " there by not returning any thing back to the client. Helps to check the server side"
+ " performance. Uses FilterAllFilter internally. ");
System.err.println(" latency Set to report operation latencies. Default: False");
System.err.println(" measureAfter Start to measure the latency once 'measureAfter'" +
" rows have been treated. Default: 0");
System.err.println(" bloomFilter Bloom filter type, one of " + Arrays.toString(BloomType.values()));
System.err.println(" valueSize Pass value size to use: Default: 1024");
System.err.println(" valueRandom Set if we should vary value size between 0 and " +
@ -1808,6 +1822,12 @@ public class PerformanceEvaluation extends Configured implements Tool {
continue;
}
final String measureAfter = "--measureAfter=";
if (cmd.startsWith(measureAfter)) {
opts.measureAfter = Integer.parseInt(cmd.substring(measureAfter.length()));
continue;
}
final String bloomFilter = "--bloomFilter=";
if (cmd.startsWith(bloomFilter)) {
opts.bloomType = BloomType.valueOf(cmd.substring(bloomFilter.length()));