honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

more append benchmark

This commit is contained in:
kimchy 2011-01-16 12:47:54 +02:00
parent 285afe8053
commit 1f289df128
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/benchmark/micro/src/main/java/org/elasticsearch/benchmark/fs/FsAppendBenchmark.java
View File

@ -40,12 +40,12 @@ public class FsAppendBenchmark {
boolean CHANNEL = true;
int CHUNK = (int) ByteSizeValue.parseBytesSizeValue("1k").bytes();
long DATA = ByteSizeValue.parseBytesSizeValue("100mb").bytes();
long DATA = ByteSizeValue.parseBytesSizeValue("10gb").bytes();
byte[] data = new byte[CHUNK];
new Random().nextBytes(data);
StopWatch watch = new StopWatch().start();
StopWatch watch = new StopWatch().start("write");
if (CHANNEL) {
FileChannel channel = raf.getChannel();
long position = 0;
@ -53,6 +53,7 @@ public class FsAppendBenchmark {
channel.write(ByteBuffer.wrap(data), position);
position += data.length;
}
watch.stop().start("flush");
channel.force(true);
} else {
long position = 0;
@ -60,11 +61,12 @@ public class FsAppendBenchmark {
raf.write(data);
position += data.length;
}
watch.stop().start("flush");
raf.getFD().sync();
}
raf.close();
watch.stop();
System.out.println("Wrote [" + (new ByteSizeValue(DATA)) + "], chunk [" + (new ByteSizeValue(CHUNK)) + "], in " + watch.lastTaskTime());
System.out.println("Wrote [" + (new ByteSizeValue(DATA)) + "], chunk [" + (new ByteSizeValue(CHUNK)) + "], in " + watch);
}
private static final ByteBuffer fill = ByteBuffer.allocateDirect(1);