influxdata/influxdb-java

package org.influxdb.impl;

import org.influxdb.InfluxDB;
import org.influxdb.dto.BatchPoints;

import java.util.Collection;

/**
 * Batch writer that tries to write BatchPoints exactly once.
 */
class OneShotBatchWriter implements BatchWriter {

  private InfluxDB influxDB;

  OneShotBatchWriter(final InfluxDB influxDB) {
    this.influxDB = influxDB;
  }

  @Override
  public void write(final Collection<BatchPoints> batchPointsCollection) {
    for (BatchPoints batchPoints : batchPointsCollection) {
      influxDB.write(batchPoints);
    }
  }

  @Override
  public void close() {

  }
}