Interface BatchResultIterable<T>

Type Parameters:

T - The generic type for the iterable.

All Superinterfaces:

Iterable<T>, ResultIterable<T>

public interface BatchResultIterable<T>
extends ResultIterable<T>

Extend the ResultIterable for batch operations.

Nested Class Summary

Nested classes/interfaces inherited from interface ResultIterable

ResultIterable.ResultIteratorDelegate<T,R>

Modifier and Type	Interface	Description
static class	ResultIterable.ResultIteratorDelegate<T,R>	An implementation of ResultIterator that delegates calls to the iterator provided in the constructor.

Method Summary

Modifier and Type	Method	Description
List<List<T>>	listPerBatch()	Split the results into per-batch sub-lists.
static <U> BatchResultIterable<U>	of(ResultIterable<U> delegate, Supplier<int[]> modifiedRowCountsSupplier)

Methods inherited from interface Iterable

spliterator

Methods inherited from interface ResultIterable

collect, collectInto, collectInto, collectIntoList, collectIntoSet, collectToMap, filter, findFirst, findOne, findOnly, first, forEach, forEachWithCount, iterator, list, map, one, reduce, set, stream, toCollection, useIterator, useStream, withIterator, withStream

Modifier and Type	Method	Description
default <R> R	collect(Collector<? super T, ?, R> collector)	Collect the results into a container specified by a collector.
default <R> R	collectInto(Type containerType)	Collect the results into a container type.
default <R> R	collectInto(GenericType<R> containerType)	Collect the results into a collection type.
default List<T>	collectIntoList()	Returns results in a List.
default Set<T>	collectIntoSet()	Returns results in a Set.
default <K,V> Map<K,V>	collectToMap(Function<? super T, ? extends K> keyFunction, Function<? super T, ? extends V> valueFunction)	Collect the results into a Map, using the given functions to compute keys and values.
default ResultIterable<T>	filter(Predicate<? super T> predicate)	Convenience method to filter the ResultIterable by applying the specified Predicate. This method has the look and feel of Stream.filter(Predicate) without making use of streams.
default Optional<T>	findFirst()	Returns the first row in the result set, if present.
default Optional<T>	findOne()	Returns the only row in the result set, if any.
default T	findOnly()	Deprecated, for removal: This API element is subject to removal in a future version. use ResultIterable.one() or ResultIterable.findOne() instead.
default T	first()	Returns the first row in the result set.
default void	forEach(Consumer<? super T> action)
default int	forEachWithCount(Consumer<? super T> action)	Performs the specified action on each remaining element and returns the iteration i.e. record count. It is often useful (e.g. for logging) to know the record count while processing result sets.
ResultIterator<T>	iterator()	Stream all the rows of the result set out with an Iterator.
default List<T>	list()	Returns results in a List using the JDK specific default implementation of List as provided by Collectors.toList().
default <R> ResultIterable<R>	map(Function<? super T, ? extends R> mapper)	Returns a ResultIterable<U> derived from this ResultIterable<T>, by transforming elements using the given mapper function.
default T	one()	Returns the only row in the result set.
default <U> U	reduce(U identity, BiFunction<U,T,U> accumulator)	Reduce the results.
default Set<T>	set()	Returns results in a Set using the JDK specific default implementation of Set as provided by Collectors.toSet().
default Stream<T>	stream()	Returns the stream of results.
default <C extends Collection<T>> C	toCollection(Supplier<C> supplier)	Collect the results into a collection object similar to Collectors.toCollection(Supplier).
default <X extends Exception> void	useIterator(IteratorConsumer<T,X> consumer)	Passes the iterator of results to the consumer.
default <X extends Exception> void	useStream(StreamConsumer<T,X> consumer)	Passes the stream of results to the consumer.
default <R, X extends Exception> R	withIterator(IteratorCallback<T,R,X> callback)	Passes the iterator of results to the callback.
default <R, X extends Exception> R	withStream(StreamCallback<T,R,X> callback)	Passes the stream of results to the callback.

Method Details

listPerBatch

List<List<T>> listPerBatch()

Split the results into per-batch sub-lists. Note that this may not be correct if any of the executed batches returned an error code.

Returns:

results in a List of Lists.

of

static <U> BatchResultIterable<U> of(ResultIterable<U> delegate,
 Supplier<int[]> modifiedRowCountsSupplier)