Skip to content

Commit aed254c

Browse files
committed
comment
1 parent 3618e9d commit aed254c

File tree

1 file changed

+4
-0
lines changed
  • java-client/src/main/java/co/elastic/clients/elasticsearch/_helpers/bulk

1 file changed

+4
-0
lines changed

java-client/src/main/java/co/elastic/clients/elasticsearch/_helpers/bulk/BulkIngester.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -502,6 +502,10 @@ public Builder<Context> flushInterval(long value, TimeUnit unit, ScheduledExecut
502502
return flushInterval(value, unit);
503503
}
504504

505+
/**
506+
* Sets a custom scheduler to run the flush thread and the listener logic. A default one is used if
507+
* not set.
508+
*/
505509
public Builder<Context> scheduler(ScheduledExecutorService scheduler) {
506510
this.scheduler = scheduler;
507511
return this;

0 commit comments

Comments
 (0)