Package org.eclipse.collections.impl.lazy.parallel

Class ParallelDistinctIterable<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.ParallelDistinctIterable<T>

All Implemented Interfaces:

ParallelIterable<T>, ParallelSetIterable<T>, ParallelUnsortedSetIterable<T>

public class ParallelDistinctIterable<T>
extends AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>

Constructor Summary

Constructors

Constructor	Description
ParallelDistinctIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate)

Method Summary

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)

Methods inherited from class org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable

collect, collectIf, collectWith, flatCollect, reject, rejectWith, select, selectInstancesOf, selectWith

Methods inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable

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

Methods inherited from class java.lang.Object

equals, 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

Constructor Details

ParallelDistinctIterable

public ParallelDistinctIterable(AbstractParallelIterable<T,? extends Batch<T>> delegate)

Method Details

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in class AbstractParallelIterable<T,UnsortedSetBatch<T>>

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in class AbstractParallelIterable<T,UnsortedSetBatch<T>>

split

public LazyIterable<UnsortedSetBatch<T>> split()

Specified by:

split in class AbstractParallelIterable<T,UnsortedSetBatch<T>>

asUnique

public ParallelUnsortedSetIterable<T> asUnique()

Specified by:

asUnique in interface ParallelIterable<T>

Specified by:

asUnique in interface ParallelSetIterable<T>

Specified by:

asUnique in interface ParallelUnsortedSetIterable<T>

Overrides:

asUnique in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>

forEach

public void forEach(Procedure<? super T> procedure)

anySatisfy

public boolean anySatisfy(Predicate<? super T> predicate)

allSatisfy

public boolean allSatisfy(Predicate<? super T> predicate)

detect

public T detect(Predicate<? super T> predicate)

toArray

public Object[] toArray()

toArray

public <E> E[] toArray(E[] array)

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelIterable<T,UnsortedSetBatch<T>>

groupBy

public <V> UnsortedSetMultimap<V,T> groupBy(Function<? super T,? extends V> function)

Specified by:

groupBy in interface ParallelIterable<T>

Specified by:

groupBy in interface ParallelSetIterable<T>

Specified by:

groupBy in interface ParallelUnsortedSetIterable<T>

Overrides:

groupBy in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>

groupByEach

public <V> UnsortedSetMultimap<V,T> groupByEach(Function<? super T,? extends Iterable<V>> function)

Specified by:

groupByEach in interface ParallelIterable<T>

Specified by:

groupByEach in interface ParallelSetIterable<T>

Specified by:

groupByEach in interface ParallelUnsortedSetIterable<T>

Overrides:

groupByEach in class AbstractParallelUnsortedSetIterable<T,UnsortedSetBatch<T>>

groupByUniqueKey

public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)

Specified by:

groupByUniqueKey in interface ParallelIterable<T>

Overrides:

groupByUniqueKey in class AbstractParallelIterable<T,UnsortedSetBatch<T>>