IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

linebreak on payloads for elastic _bulk endpoint

Browse Source
This commit is contained in:
phact
2023-08-29 22:05:01 -04:00
parent e4903c37b9
commit 68b7f758f5
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
adapter-http/src/main/java/io/nosqlbench/adapter/http/core/HttpOpDispenser.java
View File

@@ -46,9 +46,10 @@ public class HttpOpDispenser extends BaseOpDispenser<HttpOp, HttpSpace> {
LongFunction<HttpRequest.Builder> builderF = l -> HttpRequest.newBuilder(); LongFunction<HttpRequest.Builder> builderF = l -> HttpRequest.newBuilder();
LongFunction<String> bodyF = op.getAsFunctionOr("body", null); LongFunction<String> bodyF = op.getAsFunctionOr("body", null);
LongFunction<HttpRequest.BodyPublisher> bodyPublisherF = LongFunction<HttpRequest.BodyPublisher> bodyPublisherF =
l -> Optional.ofNullable(bodyF.apply(l)).map(HttpRequest.BodyPublishers::ofString).orElse( l -> Optional.ofNullable(bodyF.apply(l))
HttpRequest.BodyPublishers.noBody() .map(s -> s + "\n") // the elastic _bulk endpoint requires a newline at the end of the body
); .map(HttpRequest.BodyPublishers::ofString)
.orElse(HttpRequest.BodyPublishers.noBody());
LongFunction<String> methodF = op.getAsFunctionOr("method", "GET"); LongFunction<String> methodF = op.getAsFunctionOr("method", "GET");
LongFunction<HttpRequest.Builder> initBuilderF = LongFunction<HttpRequest.Builder> initBuilderF =