ParallelListIterable<T>, ParallelIterable<T>public class ParallelFlatCollectListIterable<T,V> extends AbstractParallelListIterable<V,ListBatch<V>>
| Constructor | Description |
|---|---|
ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable,
Function<? super T,? extends java.lang.Iterable<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() |
|
java.util.concurrent.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, toStringasUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, groupByUniqueKey, reject, rejectWith, select, selectInstancesOf, selectWith, toArray, toArrayequals, getClass, hashCode, notify, notifyAll, wait, wait, waitaggregateBy, 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, toSortedSetBypublic ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable, Function<? super T,? extends java.lang.Iterable<V>> function)
public java.util.concurrent.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–2018. All rights reserved.