public void writeBatch ( final Point ... point ) { val batchPoints = BatchPoints . database ( influxDbProperties . getDatabase ( ) ) . retentionPolicy ( influxDbProperties . getRetentionPolicy ( ) ) . consistency ( InfluxDB . ConsistencyLevel . valueOf ( influxDbProperties . getConsistencyLevel ( ) ) ) . build ( ) ; Arrays . stream ( point ) . forEach ( batchPoints :: point ) ; influxDb . write ( batchPoints ) ; }
Write synchronized batch .