public class ParallelCollectUnsortedBag<T,V> extends AbstractParallelUnsortedBag<V,UnsortedBagBatch<V>>
Constructor and Description |
---|
ParallelCollectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<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) |
void |
forEachWithOccurrences(ObjectIntProcedure<? super V> procedure) |
int |
getBatchSize() |
ExecutorService |
getExecutorService() |
LazyIterable<UnsortedBagBatch<V>> |
split() |
asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, reject, rejectWith, select, selectInstancesOf, selectWith, toBag
aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, appendString, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, groupByUniqueKey, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toArray, toArray, 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, groupByUniqueKey, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toArray, toArray, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy
public ParallelCollectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable, Function<? super T,? extends V> function)
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<V,UnsortedBagBatch<V>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<V,UnsortedBagBatch<V>>
public LazyIterable<UnsortedBagBatch<V>> split()
split
in class AbstractParallelIterable<V,UnsortedBagBatch<V>>
public void forEachWithOccurrences(ObjectIntProcedure<? super V> procedure)
Copyright © 2004–2016. All rights reserved.