Skip to content

Commit 4f926c7

Browse files
Added bulkrequest - not tested yet
1 parent c832778 commit 4f926c7

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/net/delirius/jmeter/backendlistener/elasticsearch/ElasticsearchBackend.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import org.apache.jmeter.util.JMeterUtils;
99
import org.apache.jmeter.visualizers.backend.AbstractBackendListenerClient;
1010
import org.apache.jmeter.visualizers.backend.BackendListenerContext;
11+
import org.elasticsearch.action.bulk.BulkRequestBuilder;
1112
import org.elasticsearch.client.Client;
1213
//import org.elasticsearch.client.transport.TransportClient;
1314
import org.elasticsearch.common.transport.InetSocketTransportAddress;
@@ -78,10 +79,15 @@ public void setupTest(BackendListenerContext context) throws Exception {
7879

7980
@Override
8081
public void handleSampleResults(List<SampleResult> results, BackendListenerContext context) {
82+
BulkRequestBuilder bulkRequest = client.prepareBulk();
83+
8184
for(SampleResult sr : results) {
8285
Map<String, Object> jsonObject = getElasticData(sr, context);
83-
this.client.prepareIndex(this.index, this.indexType).setSource(jsonObject, XContentType.JSON).get();
86+
bulkRequest.add(this.client.prepareIndex(this.index, this.indexType).setSource(jsonObject, XContentType.JSON));
8487
}
88+
89+
if(bulkRequest.numberOfActions() >= 50)
90+
bulkRequest.get();
8591
}
8692

8793
@Override

0 commit comments

Comments
 (0)