public interface BatchOperationManager
Modifier and Type | Method and Description |
---|---|
default <I,O> Iterable<O> |
applyInBatches(Iterable<I> input,
int expectedTotal,
Function<I,O> task)
Executes a task for each item in a collection in batches
|
default <I,O> Iterable<O> |
applyInBatches(Iterable<I> input,
int batchSize,
int expectedTotal,
Function<I,O> task)
Executes a task for each item in a collection in batches with configurable batch size
|
default <I,O> Iterable<O> |
applyInChunks(Iterable<I> input,
int chunkSize,
int sizeToCollect,
Function<List<I>,List<O>> task)
Processes a collection of items in chunks until a given number of processed items is reached, the processed items
are then returned.
|
<I,O> Iterable<O> |
performAsBatch(Iterable<I> input,
int expectedTotal,
com.google.common.base.Function<I,O> task)
Deprecated.
since 7.0.1. Use
applyInBatches(Iterable, int, Function) |
<I,O> Iterable<O> |
performAsBatch(Iterable<I> input,
int batchSize,
int expectedTotal,
com.google.common.base.Function<I,O> task)
Deprecated.
since 7.0.1. Use
applyInBatches(Iterable, int, int, Function) |
<I,O> Iterable<O> |
performInChunks(Iterable<I> input,
int chunkSize,
int sizeToCollect,
com.google.common.base.Function<List<I>,List<O>> task)
Deprecated.
since 7.0.1. Use
applyInChunks(Iterable, int, int, Function) |
@Deprecated <I,O> Iterable<O> performAsBatch(Iterable<I> input, int batchSize, int expectedTotal, com.google.common.base.Function<I,O> task)
applyInBatches(Iterable, int, int, Function)
I
- input typeO
- output typeinput
- the items to processbatchSize
- the size of the batchexpectedTotal
- the expected number of items to processtask
- a function to process the itemsdefault <I,O> Iterable<O> applyInBatches(Iterable<I> input, int batchSize, int expectedTotal, Function<I,O> task)
I
- input typeO
- output typeinput
- the items to processbatchSize
- the size of the batchexpectedTotal
- the expected number of items to processtask
- a function to process the items@Deprecated <I,O> Iterable<O> performAsBatch(Iterable<I> input, int expectedTotal, com.google.common.base.Function<I,O> task)
applyInBatches(Iterable, int, Function)
I
- input typeO
- output typeinput
- the items to processexpectedTotal
- the expected number of items to processtask
- a function to process the itemsdefault <I,O> Iterable<O> applyInBatches(Iterable<I> input, int expectedTotal, Function<I,O> task)
I
- input typeO
- output typeinput
- the items to processexpectedTotal
- the expected number of items to processtask
- a function to process the items@Deprecated <I,O> Iterable<O> performInChunks(Iterable<I> input, int chunkSize, int sizeToCollect, com.google.common.base.Function<List<I>,List<O>> task)
applyInChunks(Iterable, int, int, Function)
input
- the items to processchunkSize
- the size of the batchsizeToCollect
- the number of processed items to returntask
- a function to process the itemsdefault <I,O> Iterable<O> applyInChunks(Iterable<I> input, int chunkSize, int sizeToCollect, Function<List<I>,List<O>> task)
input
- the items to processchunkSize
- the size of the batchsizeToCollect
- the number of processed items to returntask
- a function to process the itemsCopyright © 2003–2020 Atlassian. All rights reserved.