ParallelIterable<T>
public class ParallelFlatCollectIterable<T,V> extends AbstractParallelIterableImpl<V,Batch<V>>
Constructor | Description |
---|---|
ParallelFlatCollectIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate,
Function<? super T,? extends 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() |
|
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) |
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, reject, rejectWith, select, selectInstancesOf, selectWith
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
appendString, appendString, makeString, makeString, makeString, toSortedList
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()
public <E> E[] toArray(E[] array)
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelIterable<V,Batch<V>>
public <V1> UnsortedBagMultimap<V1,V> groupBy(Function<? super V,? extends V1> function)
groupBy
in interface ParallelIterable<T>
groupBy
in class AbstractParallelIterableImpl<V,Batch<V>>
public <V1> UnsortedBagMultimap<V1,V> groupByEach(Function<? super V,? extends Iterable<V1>> function)
groupByEach
in interface ParallelIterable<T>
groupByEach
in class AbstractParallelIterableImpl<V,Batch<V>>
public <V1> MapIterable<V1,V> groupByUniqueKey(Function<? super V,? extends V1> function)
groupByUniqueKey
in interface ParallelIterable<T>
groupByUniqueKey
in class AbstractParallelIterable<V,Batch<V>>
Copyright © 2004–2019. All rights reserved.