Class ParallelFlatCollectIterable<T,V>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<V,Batch<V>>

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterableImpl<V,Batch<V>>

org.eclipse.collections.impl.lazy.parallel.set.ParallelFlatCollectIterable<T,V>

All Implemented Interfaces:

ParallelIterable<V>

public class ParallelFlatCollectIterable<T,V>
extends AbstractParallelIterableImpl<V,Batch<V>>

Field Summary

Fields

Modifier and Type	Field	Description
private final AbstractParallelIterable<T, ? extends Batch<T>>	delegate
private final Function<? super T, ? extends Iterable<V>>	function

Constructor Summary

Constructors

Constructor	Description
ParallelFlatCollectIterable(AbstractParallelIterable<T, ? extends Batch<T>> delegate, Function<? super T, ? extends Iterable<V>> function)

Method Summary

Modifier and Type	Method	Description
boolean	allSatisfy(Predicate<? super V> predicate)
boolean	anySatisfy(Predicate<? super V> predicate)
V	detect(Predicate<? super V> predicate)
void	forEach(Procedure<? super V> procedure)
int	getBatchSize()
ExecutorService	getExecutorService()
<V1> UnsortedBagMultimap<V1,V>	groupBy(Function<? super V, ? extends V1> function)
<V1> UnsortedBagMultimap<V1,V>	groupByEach(Function<? super V, ? extends Iterable<V1>> function)
<V1> MapIterable<V1,V>	groupByUniqueKey(Function<? super V, ? extends V1> function)
LazyIterable<Batch<V>>	split()
Object[]	toArray()
<E> E[]	toArray(E[] array)

Methods inherited from class AbstractParallelIterableImpl

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

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ParallelIterable

appendString, appendString, makeString, makeString, makeString, makeString, toSortedList

Field Details

delegate

private final AbstractParallelIterable<T, ? extends Batch<T>> delegate

function

private final Function<? super T, ? extends Iterable<V>> function

Constructor Details

ParallelFlatCollectIterable

public ParallelFlatCollectIterable(AbstractParallelIterable<T, ? extends Batch<T>> delegate,
 Function<? super T, ? extends Iterable<V>> function)

Method Details

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in class AbstractParallelIterable<V,Batch<V>>

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in class AbstractParallelIterable<V,Batch<V>>

split

public LazyIterable<Batch<V>> split()

Specified by:

split in class AbstractParallelIterable<V,Batch<V>>

forEach

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

detect

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

anySatisfy

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

allSatisfy

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

toArray

public Object[] toArray()

toArray

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

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelIterable<V,Batch<V>>

groupBy

public <V1> UnsortedBagMultimap<V1,V> groupBy(Function<? super V, ? extends V1> function)

Specified by:

groupBy in interface ParallelIterable<T>

Overrides:

groupBy in class AbstractParallelIterableImpl<V,Batch<V>>

groupByEach

public <V1> UnsortedBagMultimap<V1,V> groupByEach(Function<? super V, ? extends Iterable<V1>> function)

Specified by:

groupByEach in interface ParallelIterable<T>

Overrides:

groupByEach in class AbstractParallelIterableImpl<V,Batch<V>>

groupByUniqueKey

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

Specified by:

groupByUniqueKey in interface ParallelIterable<T>

Overrides:

groupByUniqueKey in class AbstractParallelIterable<V,Batch<V>>