Page History

...

/**
 * Enable batching of single Point writes to speed up writes significantly. This is the same as calling
 */
public InfluxDB enableBatch();

/**
 * Enable batching of single Point writes to speed up writes significantly. If either number of points written or
 * flushDuration time limit is reached, a batch write is issued.
 * Note that batch processing needs to be explicitly stopped before the application is shutdown.
 * To do so call disableBatch().
 */
public InfluxDB enableBatch(final BatchOptions batchOptions);

/**
 * Enable batching of single Point writes as {@link #enableBatch(int, int, TimeUnit, ThreadFactory)}}
 */
public InfluxDB enableBatch(final int actions, final int flushDuration, final TimeUnit flushDurationTimeUnit);

/**
 * Enable batching of single Point writes as
 * {@link #enableBatch(int, int, TimeUnit, ThreadFactory, BiConsumer)}
 * using with a exceptionHandler that does nothing.
 */
public InfluxDB enableBatch(final int actions, final int flushDuration, final TimeUnit flushDurationTimeUnit,
                            final ThreadFactory threadFactory);
/**
 * Enable batching of single Point writes with consistency set for an entire batch
 * flushDurations is reached first, a batch write is issued.
 * Note that batch processing needs to be explicitly stopped before the application is shutdown.
 * To do so call disableBatch(). Default consistency is ONE.
 */

InfluxDB enableBatch(int actions, int flushDuration, TimeUnit flushDurationTimeUnit,
                     ThreadFactory threadFactory, BiConsumer<Iterable<Point>, Throwable> exceptionHandler,
                     ConsistencyLevel consistency);

/**
 * Enable batching of single Point writes to speed up writes significant. If either actions or
 * flushDurations is reached first, a batch write is issued.
 * Note that batch processing needs to be explicitly stopped before the application is shutdown.
 * To do so call disableBatch().
 */
public InfluxDB enableBatch(final int actions, final int flushDuration, final TimeUnit flushDurationTimeUnit,
                            final ThreadFactory threadFactory,
                            final BiConsumer<Iterable<Point>, Throwable> exceptionHandler);

6. disableBatch()

/**
 * Disable Batching.
 */
public void disableBatch();

7. disableBatch()

/**
 * Returns whether Batching is enabled.
 */
public boolean isBatchEnabled();

8. setConsistency()

/**
 * Set the consistency level which is used for writing points.
 */
public InfluxDB setConsistency(final ConsistencyLevel consistency)

9. setRetentionPolicy()

/**
 * Set the retention policy which is used for writing points.
 */
public InfluxDB setRetentionPolicy(final String retentionPolicy);