public class BatchProcessor<T>
extends java.lang.Object
| Constructor and Description |
|---|
BatchProcessor(long batchInterval,
int batchSize,
java.util.function.Consumer<java.util.List<T>> consumer,
java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
void |
add(T item) |
void |
close() |
void |
configure(long batchInterval,
int batchSize) |
public BatchProcessor(long batchInterval,
int batchSize,
java.util.function.Consumer<java.util.List<T>> consumer,
java.lang.String name)
public void add(T item)
public void close()
public void configure(long batchInterval,
int batchSize)