ParallelListIterable<T>
, ParallelIterable<T>
public class ParallelCollectListIterable<T,V> extends AbstractParallelListIterable<V,ListBatch<V>>
Constructor | Description |
---|---|
ParallelCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable,
Function<? super T,? extends V> function) |
Modifier and Type | Method | 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() |
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
asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, groupByUniqueKey, reject, rejectWith, select, selectInstancesOf, selectWith, toArray, toArray
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–2019. All rights reserved.