public class ParallelFlatCollectListIterable<T,V> extends AbstractParallelListIterable<V,ListBatch<V>>
Constructor and Description |
---|
ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable,
Function<? super T,? extends Iterable<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, 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 ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable, Function<? super T,? extends Iterable<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–2017. All rights reserved.