Class ParallelDistinctListIterable<T>
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>
-
- org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
-
- org.eclipse.collections.impl.lazy.parallel.list.ParallelDistinctListIterable<T>
-
- All Implemented Interfaces:
ParallelIterable<T>
,ParallelSetIterable<T>
,ParallelUnsortedSetIterable<T>
class ParallelDistinctListIterable<T> extends AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
ParallelDistinctListIterable.DistinctAndPredicate<T>
private static class
ParallelDistinctListIterable.DistinctOrPredicate<T>
-
Field Summary
Fields Modifier and Type Field Description private AbstractParallelListIterable<T,? extends ListBatch<T>>
delegate
-
Constructor Summary
Constructors Constructor Description ParallelDistinctListIterable(AbstractParallelListIterable<T,? extends ListBatch<T>> delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods 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()
java.util.concurrent.ExecutorService
getExecutorService()
<V> UnsortedSetMultimap<V,T>
groupBy(Function<? super T,? extends V> function)
<V> UnsortedSetMultimap<V,T>
groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
<V> MapIterable<V,T>
groupByUniqueKey(Function<? super T,? extends V> function)
LazyIterable<UnsortedSetBatch<T>>
split()
java.lang.Object[]
toArray()
<E> E[]
toArray(E[] array)
-
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable
collect, collectIf, collectWith, flatCollect, isOrdered, reject, rejectWith, select, selectInstancesOf, selectWith
-
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable
aggregateBy, aggregateInPlaceBy, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, collectCombine, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, 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
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.collections.api.ParallelIterable
aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, appendString, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, makeString, 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
-
-
-
-
Field Detail
-
delegate
private final AbstractParallelListIterable<T,? extends ListBatch<T>> delegate
-
-
Constructor Detail
-
ParallelDistinctListIterable
ParallelDistinctListIterable(AbstractParallelListIterable<T,? extends ListBatch<T>> delegate)
-
-
Method Detail
-
getExecutorService
public java.util.concurrent.ExecutorService getExecutorService()
- Specified by:
getExecutorService
in classAbstractParallelIterable<T,UnsortedSetBatch<T>>
-
getBatchSize
public int getBatchSize()
- Specified by:
getBatchSize
in classAbstractParallelIterable<T,UnsortedSetBatch<T>>
-
split
public LazyIterable<UnsortedSetBatch<T>> split()
- Specified by:
split
in classAbstractParallelIterable<T,UnsortedSetBatch<T>>
-
asUnique
public ParallelUnsortedSetIterable<T> asUnique()
- Specified by:
asUnique
in interfaceParallelIterable<T>
- Specified by:
asUnique
in interfaceParallelSetIterable<T>
- Specified by:
asUnique
in interfaceParallelUnsortedSetIterable<T>
- Overrides:
asUnique
in classAbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
-
toArray
public java.lang.Object[] toArray()
-
toArray
public <E> E[] toArray(E[] array)
- Specified by:
toArray
in interfaceParallelIterable<T>
- Overrides:
toArray
in classAbstractParallelIterable<T,UnsortedSetBatch<T>>
-
groupBy
public <V> UnsortedSetMultimap<V,T> groupBy(Function<? super T,? extends V> function)
- Specified by:
groupBy
in interfaceParallelIterable<T>
- Specified by:
groupBy
in interfaceParallelSetIterable<T>
- Specified by:
groupBy
in interfaceParallelUnsortedSetIterable<T>
- Overrides:
groupBy
in classAbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
-
groupByEach
public <V> UnsortedSetMultimap<V,T> groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
- Specified by:
groupByEach
in interfaceParallelIterable<T>
- Specified by:
groupByEach
in interfaceParallelSetIterable<T>
- Specified by:
groupByEach
in interfaceParallelUnsortedSetIterable<T>
- Overrides:
groupByEach
in classAbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>
-
groupByUniqueKey
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
- Specified by:
groupByUniqueKey
in interfaceParallelIterable<T>
- Overrides:
groupByUniqueKey
in classAbstractParallelIterable<T,UnsortedSetBatch<T>>
-
-