How to do batch write with block api?

[lonelyleaf]

Proposal:
batch write data with block api

Use case:
I need import data from file and batch write with block api,but I notice that although WriteApiBlocking.writePoints( String bucket, String org, List<Point> points) accept collection of points,but the implementation of it write data one by one,which is too slow in my use case.

By the way, when I tried your non-blocking api,sometime it create too many TIMED_WAITING thread,and casue oom finally.

threaddump-1604541290817.zip

[bednar]

@lonelyleaf thanks, we will take a look

[bednar]

PR with fix is prepared #176. Meanwhile you could use this workaround:

List<String> records = points.stream().map(Point::toLineProtocol).collect(Collectors.toList());

influxDBClient
    .getWriteApiBlocking()
    .writeRecords("b1", "org1", WritePrecision.NS, records);

[lonelyleaf]

@bednar thanks