public final class ListIterableParallelIterable<T> extends AbstractParallelListIterable<T,RootListBatch<T>>
Constructor and Description |
---|
ListIterableParallelIterable(ListIterable<T> delegate,
ExecutorService executorService,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
allSatisfy(Predicate<? super T> predicate) |
boolean |
anySatisfy(Predicate<? super T> predicate) |
T |
detect(Predicate<? super T> predicate) |
<V> ParallelListIterable<V> |
flatCollect(Function<? super T,? extends Iterable<V>> function)
Creates a parallel flattening iterable for the current iterable.
|
void |
forEach(Procedure<? super T> procedure) |
int |
getBatchSize() |
ExecutorService |
getExecutorService() |
<V> ListMultimap<V,T> |
groupBy(Function<? super T,? extends V> function) |
<V> ListMultimap<V,T> |
groupByEach(Function<? super T,? extends Iterable<V>> function) |
<V> MapIterable<V,T> |
groupByUniqueKey(Function<? super T,? extends V> function) |
LazyIterable<RootListBatch<T>> |
split() |
Object[] |
toArray() |
<E> E[] |
toArray(E[] array) |
asUnique, collect, collectIf, collectWith, 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
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 ListIterableParallelIterable(ListIterable<T> delegate, ExecutorService executorService, int batchSize)
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<T,RootListBatch<T>>
public LazyIterable<RootListBatch<T>> split()
split
in class AbstractParallelIterable<T,RootListBatch<T>>
public <V> ParallelListIterable<V> flatCollect(Function<? super T,? extends Iterable<V>> function)
ParallelListIterable
flatCollect
in interface ParallelListIterable<T>
flatCollect
in interface ParallelIterable<T>
flatCollect
in class AbstractParallelListIterable<T,RootListBatch<T>>
public Object[] toArray()
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <E> E[] toArray(E[] array)
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> ListMultimap<V,T> groupBy(Function<? super T,? extends V> function)
groupBy
in interface ParallelListIterable<T>
groupBy
in interface ParallelIterable<T>
groupBy
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> ListMultimap<V,T> groupByEach(Function<? super T,? extends Iterable<V>> function)
groupByEach
in interface ParallelListIterable<T>
groupByEach
in interface ParallelIterable<T>
groupByEach
in class AbstractParallelListIterable<T,RootListBatch<T>>
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
groupByUniqueKey
in interface ParallelIterable<T>
groupByUniqueKey
in class AbstractParallelListIterable<T,RootListBatch<T>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<T,RootListBatch<T>>
Copyright © 2004–2016. All rights reserved.