Class AbstractParallelIterableImpl<T,B extends Batch<T>>
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterableImpl<T,B>
-
- All Implemented Interfaces:
ParallelIterable<T>
- Direct Known Subclasses:
ParallelCollectIterable
,ParallelFlatCollectIterable
,ParallelSelectIterable
public abstract class AbstractParallelIterableImpl<T,B extends Batch<T>> extends AbstractParallelIterable<T,B>
-
-
Constructor Summary
Constructors Constructor Description AbstractParallelIterableImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ParallelUnsortedSetIterable<T>
asUnique()
<V> ParallelIterable<V>
collect(Function<? super T,? extends V> function)
Creates a parallel iterable for collecting elements from the current iterable.<V> ParallelIterable<V>
collectIf(Predicate<? super T> predicate, Function<? super T,? extends V> function)
Creates a parallel iterable for selecting and collecting elements from the current iterable.<P,V>
ParallelIterable<V>collectWith(Function2<? super T,? super P,? extends V> function, P parameter)
<V> ParallelIterable<V>
flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function)
Creates a parallel flattening iterable for the current iterable.<V> UnsortedBagMultimap<V,T>
groupBy(Function<? super T,? extends V> function)
<V> UnsortedBagMultimap<V,T>
groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
protected boolean
isOrdered()
ParallelIterable<T>
reject(Predicate<? super T> predicate)
Creates a parallel iterable for rejecting elements from the current iterable.<P> ParallelIterable<T>
rejectWith(Predicate2<? super T,? super P> predicate, P parameter)
ParallelIterable<T>
select(Predicate<? super T> predicate)
Creates a parallel iterable for selecting elements from the current iterable.<S> ParallelIterable<S>
selectInstancesOf(java.lang.Class<S> clazz)
<P> ParallelIterable<T>
selectWith(Predicate2<? super T,? super P> predicate, P parameter)
-
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, getBatchSize, getExecutorService, groupByUniqueKey, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, split, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toArray, 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
allSatisfy, anySatisfy, appendString, appendString, detect, forEach, makeString, makeString, makeString, makeString, toArray, toSortedList
-
-
-
-
Method Detail
-
isOrdered
protected boolean isOrdered()
-
asUnique
public ParallelUnsortedSetIterable<T> asUnique()
-
select
public ParallelIterable<T> select(Predicate<? super T> predicate)
Description copied from interface:ParallelIterable
Creates a parallel iterable for selecting elements from the current iterable.
-
selectWith
public <P> ParallelIterable<T> selectWith(Predicate2<? super T,? super P> predicate, P parameter)
-
selectInstancesOf
public <S> ParallelIterable<S> selectInstancesOf(java.lang.Class<S> clazz)
-
reject
public ParallelIterable<T> reject(Predicate<? super T> predicate)
Description copied from interface:ParallelIterable
Creates a parallel iterable for rejecting elements from the current iterable.
-
rejectWith
public <P> ParallelIterable<T> rejectWith(Predicate2<? super T,? super P> predicate, P parameter)
-
collect
public <V> ParallelIterable<V> collect(Function<? super T,? extends V> function)
Description copied from interface:ParallelIterable
Creates a parallel iterable for collecting elements from the current iterable.
-
collectWith
public <P,V> ParallelIterable<V> collectWith(Function2<? super T,? super P,? extends V> function, P parameter)
-
collectIf
public <V> ParallelIterable<V> collectIf(Predicate<? super T> predicate, Function<? super T,? extends V> function)
Description copied from interface:ParallelIterable
Creates a parallel iterable for selecting and collecting elements from the current iterable.
-
flatCollect
public <V> ParallelIterable<V> flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function)
Description copied from interface:ParallelIterable
Creates a parallel flattening iterable for the current iterable.
-
groupBy
public <V> UnsortedBagMultimap<V,T> groupBy(Function<? super T,? extends V> function)
-
groupByEach
public <V> UnsortedBagMultimap<V,T> groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
-
-