public final class ListIterableParallelIterable<T> extends AbstractParallelListIterable<T,RootListBatch<T>>
Constructor and Description |
---|
ListIterableParallelIterable(ListIterable<T> delegate,
ExecutorService executorService,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
allSatisfy(Predicate<? super T> predicate) |
boolean |
anySatisfy(Predicate<? super T> predicate) |
T |
detect(Predicate<? super T> predicate) |
void |
forEach(Procedure<? super T> procedure) |
int |
getBatchSize() |
ExecutorService |
getExecutorService() |
<V> ListMultimap<V,T> |
groupBy(Function<? super T,? extends V> function) |
<V> ListMultimap<V,T> |
groupByEach(Function<? super T,? extends Iterable<V>> function) |
<V> MapIterable<V,T> |
groupByUniqueKey(Function<? super T,? extends V> function) |
LazyIterable<RootListBatch<T>> |
split() |
Object[] |
toArray() |
<E> E[] |
toArray(E[] array) |
asUnique, collect, collectIf, collectWith, flatCollect, reject, rejectWith, select, selectInstancesOf, selectWith
aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy, toString
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, appendString, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy
public ListIterableParallelIterable(ListIterable<T> delegate, ExecutorService executorService, int batchSize)
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<T,RootListBatch<T>>
public LazyIterable<RootListBatch<T>> split()
split
in class AbstractParallelIterable<T,RootListBatch<T>>
public Object[] toArray()
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <E> E[] toArray(E[] array)
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> ListMultimap<V,T> groupBy(Function<? super T,? extends V> function)
groupBy
in interface ParallelListIterable<T>
groupBy
in interface ParallelIterable<T>
groupBy
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> ListMultimap<V,T> groupByEach(Function<? super T,? extends Iterable<V>> function)
groupByEach
in interface ParallelListIterable<T>
groupByEach
in interface ParallelIterable<T>
groupByEach
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
groupByUniqueKey
in interface ParallelIterable<T>
groupByUniqueKey
in class AbstractParallelListIterable<T,RootListBatch<T>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<T,RootListBatch<T>>
Copyright © 2004–2016. All rights reserved.