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