public class ParallelCollectListIterable<T,V> extends AbstractParallelListIterable<V,ListBatch<V>>
Constructor and Description |
---|
ParallelCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable,
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() |
LazyIterable<ListBatch<V>> |
split() |
asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, groupByUniqueKey, reject, rejectWith, select, selectInstancesOf, selectWith, toArray, toArray
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, 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 ParallelCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable, Function<? super T,? extends V> function)
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<V,ListBatch<V>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<V,ListBatch<V>>
public LazyIterable<ListBatch<V>> split()
split
in class AbstractParallelIterable<V,ListBatch<V>>
Copyright © 2004–2016. All rights reserved.