ParallelIterable<T>
, ParallelSetIterable<T>
, ParallelUnsortedSetIterable<T>
public class ParallelDistinctIterable<T> extends AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
Constructor | Description |
---|---|
ParallelDistinctIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate) |
Modifier and Type | Method | Description |
---|---|---|
boolean |
allSatisfy(Predicate<? super T> predicate) |
|
boolean |
anySatisfy(Predicate<? super T> predicate) |
|
ParallelUnsortedSetIterable<T> |
asUnique() |
|
T |
detect(Predicate<? super T> predicate) |
|
void |
forEach(Procedure<? super T> procedure) |
|
int |
getBatchSize() |
|
ExecutorService |
getExecutorService() |
|
<V> UnsortedSetMultimap<V,T> |
groupBy(Function<? super T,? extends V> function) |
|
<V> UnsortedSetMultimap<V,T> |
groupByEach(Function<? super T,? extends Iterable<V>> function) |
|
<V> MapIterable<V,T> |
groupByUniqueKey(Function<? super T,? extends V> function) |
|
LazyIterable<UnsortedSetBatch<T>> |
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
collect, collectIf, collectWith, flatCollect, reject, rejectWith, select, selectInstancesOf, selectWith
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 ParallelDistinctIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate)
public ExecutorService getExecutorService()
getExecutorService
in class AbstractParallelIterable<T,UnsortedSetBatch<T>>
public int getBatchSize()
getBatchSize
in class AbstractParallelIterable<T,UnsortedSetBatch<T>>
public LazyIterable<UnsortedSetBatch<T>> split()
split
in class AbstractParallelIterable<T,UnsortedSetBatch<T>>
public ParallelUnsortedSetIterable<T> asUnique()
asUnique
in interface ParallelIterable<T>
asUnique
in interface ParallelSetIterable<T>
asUnique
in interface ParallelUnsortedSetIterable<T>
asUnique
in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
public Object[] toArray()
public <E> E[] toArray(E[] array)
toArray
in interface ParallelIterable<T>
toArray
in class AbstractParallelIterable<T,UnsortedSetBatch<T>>
public <V> UnsortedSetMultimap<V,T> groupBy(Function<? super T,? extends V> function)
groupBy
in interface ParallelIterable<T>
groupBy
in interface ParallelSetIterable<T>
groupBy
in interface ParallelUnsortedSetIterable<T>
groupBy
in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
public <V> UnsortedSetMultimap<V,T> groupByEach(Function<? super T,? extends Iterable<V>> function)
groupByEach
in interface ParallelIterable<T>
groupByEach
in interface ParallelSetIterable<T>
groupByEach
in interface ParallelUnsortedSetIterable<T>
groupByEach
in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
groupByUniqueKey
in interface ParallelIterable<T>
groupByUniqueKey
in class AbstractParallelIterable<T,UnsortedSetBatch<T>>
Copyright © 2004–2019. All rights reserved.