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

better benchmark on memory monitor

This commit is contained in:
kimchy 2010-06-29 22:12:43 +03:00
parent 04ad93e8d6
commit 03ac38fdba
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
modules/benchmark/micro/src/main/java/org/elasticsearch/benchmark/monitor/memory/SimpleMemoryMonitorBenchmark.java
View File

@ -46,22 +46,24 @@ public class SimpleMemoryMonitorBenchmark {
Settings settings = settingsBuilder() Settings settings = settingsBuilder()
.put("cluster.routing.schedule", 200, TimeUnit.MILLISECONDS) .put("cluster.routing.schedule", 200, TimeUnit.MILLISECONDS)
.put("index.engine.robin.refreshInterval", 1, TimeUnit.SECONDS) .put("index.engine.robin.refreshInterval", "-1")
.put(SETTING_NUMBER_OF_SHARDS, 5) .put(SETTING_NUMBER_OF_SHARDS, 2)
.put(SETTING_NUMBER_OF_REPLICAS, 1) .put(SETTING_NUMBER_OF_REPLICAS, 1)
.build(); .build();
Node node1 = nodeBuilder().settings(settingsBuilder().put(settings).put("name", "server1")).node(); Node node1 = nodeBuilder().settings(settingsBuilder().put(settings).put("name", "server1")).node();
Node node2 = nodeBuilder().settings(settingsBuilder().put(settings).put("name", "server2")).node(); Node node2 = nodeBuilder().settings(settingsBuilder().put(settings).put("name", "server2")).node();
Client client1 = node1.client(); Node client = nodeBuilder().settings(settingsBuilder().put(settings).put("name", "client")).client(true).node();
Client client1 = client.client();
Thread.sleep(1000); Thread.sleep(1000);
client1.admin().indices().create(createIndexRequest("test")).actionGet(); client1.admin().indices().create(createIndexRequest("test")).actionGet();
Thread.sleep(5000); Thread.sleep(5000);
StopWatch stopWatch = new StopWatch().start(); StopWatch stopWatch = new StopWatch().start();
int COUNT = 2000000; int COUNT = 200000;
System.out.println("Indexing [" + COUNT + "] ..."); System.out.println("Indexing [" + COUNT + "] ...");
for (int i = 0; i < COUNT; i++) { for (int i = 0; i < COUNT; i++) {
client1.index( client1.index(
@ -76,7 +78,10 @@ public class SimpleMemoryMonitorBenchmark {
stopWatch.start(); stopWatch.start();
} }
} }
System.out.println("Indexing took " + stopWatch.stop().totalTime()); stopWatch.stop();
System.out.println("Indexing took " + stopWatch.totalTime() + ", TPS " + (((double) COUNT) / stopWatch.totalTime().secondsFrac()));
client.close();
node1.close(); node1.close();
node2.close(); node2.close();