public class ParallelFlatCollectIterable<T,V> extends AbstractParallelIterableImpl<V,Batch<V>>
Constructor and Description |
---|
ParallelFlatCollectIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate,
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() |
<V1> UnsortedBagMultimap<V1,V> |
groupBy(Function<? super V,? extends V1> function) |
<V1> UnsortedBagMultimap<V1,V> |
groupByEach(Function<? super V,? extends Iterable<V1>> function) |
<V1> MapIterable<V1,V> |
groupByUniqueKey(Function<? super V,? extends V1> function) |
LazyIterable<Batch<V>> |
split() |
Object[] |
toArray() |
<E> E[] |
toArray(E[] array) |
asUnique, collect, collectIf, collectWith, flatCollect, reject, rejectWith, select, selectInstancesOf, selectWith
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, toString
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<V,Batch<V>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<V,Batch<V>>
public LazyIterable<Batch<V>> split()
split
in class AbstractParallelIterable<V,Batch<V>>
public Object[] toArray()
toArray
in interface ParallelIterable<V>
toArray
in class AbstractParallelIterable<V,Batch<V>>
public <E> E[] toArray(E[] array)
toArray
in interface ParallelIterable<V>
toArray
in class AbstractParallelIterable<V,Batch<V>>
public <V1> UnsortedBagMultimap<V1,V> groupBy(Function<? super V,? extends V1> function)
groupBy
in interface ParallelIterable<V>
groupBy
in class AbstractParallelIterableImpl<V,Batch<V>>
public <V1> UnsortedBagMultimap<V1,V> groupByEach(Function<? super V,? extends Iterable<V1>> function)
groupByEach
in interface ParallelIterable<V>
groupByEach
in class AbstractParallelIterableImpl<V,Batch<V>>
public <V1> MapIterable<V1,V> groupByUniqueKey(Function<? super V,? extends V1> function)
groupByUniqueKey
in interface ParallelIterable<V>
groupByUniqueKey
in class AbstractParallelIterable<V,Batch<V>>
Copyright © 2004–2016. All rights reserved.