public class ParallelCollectIterable<T,V> extends AbstractParallelIterableImpl<V,Batch<V>>
| Constructor and Description |
|---|
ParallelCollectIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate,
Function<? super T,? extends V> function) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
allSatisfy(Predicate<? super V> predicate) |
boolean |
anySatisfy(Predicate<? super V> predicate) |
V |
detect(Predicate<? super V> predicate) |
void |
forEach(Procedure<? super V> procedure) |
int |
getBatchSize() |
ExecutorService |
getExecutorService() |
<V1> UnsortedBagMultimap<V1,V> |
groupBy(Function<? super V,? extends V1> function) |
<V1> UnsortedBagMultimap<V1,V> |
groupByEach(Function<? super V,? extends Iterable<V1>> function) |
<V1> MapIterable<V1,V> |
groupByUniqueKey(Function<? super V,? extends V1> function) |
LazyIterable<Batch<V>> |
split() |
Object[] |
toArray() |
<E> E[] |
toArray(E[] array) |
asUnique, collect, collectIf, collectWith, flatCollect, reject, rejectWith, select, selectInstancesOf, selectWithaggregateBy, 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, toStringequals, getClass, hashCode, notify, notifyAll, wait, wait, waitappendString, appendString, makeString, makeString, makeString, toSortedListpublic ExecutorService getExecutorService()
getExecutorService in class AbstractParallelIterable<V,Batch<V>>public int getBatchSize()
getBatchSize in class AbstractParallelIterable<V,Batch<V>>public LazyIterable<Batch<V>> split()
split in class AbstractParallelIterable<V,Batch<V>>public Object[] toArray()
public <E> E[] toArray(E[] array)
toArray in interface ParallelIterable<V>toArray in class AbstractParallelIterable<V,Batch<V>>public <V1> UnsortedBagMultimap<V1,V> groupBy(Function<? super V,? extends V1> function)
groupBy in interface ParallelIterable<V>groupBy in class AbstractParallelIterableImpl<V,Batch<V>>public <V1> UnsortedBagMultimap<V1,V> groupByEach(Function<? super V,? extends Iterable<V1>> function)
groupByEach in interface ParallelIterable<V>groupByEach in class AbstractParallelIterableImpl<V,Batch<V>>public <V1> MapIterable<V1,V> groupByUniqueKey(Function<? super V,? extends V1> function)
groupByUniqueKey in interface ParallelIterable<V>groupByUniqueKey in class AbstractParallelIterable<V,Batch<V>>Copyright © 2004–2016. All rights reserved.