public Builder setBulkFlushMaxActions(int numMaxActions){ Preconditions.checkArgument( numMaxActions > 0, "Max number of buffered actions must be larger than 0."); LOG.info("Builder config: bulkFlushMaxActions=" + numMaxActions); this.bulkRequestsConfig.put(CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS, String.valueOf(numMaxActions)); returnthis; }
public Builder setBulkFlushMaxSizeMb(int maxSizeMb){ Preconditions.checkArgument( maxSizeMb > 0, "Max size of buffered actions must be larger than 0."); LOG.info("Builder config: bulkFlushMaxSizeMb=" + maxSizeMb); this.bulkRequestsConfig.put(CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB, String.valueOf(maxSizeMb)); returnthis; }
public Builder setBulkFlushInterval(long intervalMillis){ Preconditions.checkArgument( intervalMillis >= 0, "Interval (in milliseconds) between each flush must be larger than or equal to 0."); LOG.info("Builder config: bulkFlushInterval=" + intervalMillis); this.bulkRequestsConfig.put(CONFIG_KEY_BULK_FLUSH_INTERVAL_MS, String.valueOf(intervalMillis)); returnthis; }
public Builder setBulkFlushBackoffRetries(int maxRetries){ Preconditions.checkArgument( maxRetries > 0, "Max number of backoff attempts must be larger than 0."); LOG.info("Builder config: bulkFlushBackoffRetries=" + maxRetries); this.bulkRequestsConfig.put(CONFIG_KEY_BULK_FLUSH_BACKOFF_RETRIES, String.valueOf(maxRetries)); returnthis; }
public Builder setBulkFlushBackoffDelay(long delayMillis){ Preconditions.checkArgument( delayMillis >= 0, "Delay (in milliseconds) between each backoff attempt must be larger than or equal to 0."); LOG.info("Builder config: bulkFlushBackoffDelay=" + delayMillis); this.bulkRequestsConfig.put(CONFIG_KEY_BULK_FLUSH_BACKOFF_DELAY, String.valueOf(delayMillis)); returnthis; }