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, 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 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.