Packages

implicit final class MapWrapper[V] extends AnyVal

Wrappers to map in parallel an iterator scala.Iterator.

Linear Supertypes
AnyVal, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MapWrapper
  2. AnyVal
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MapWrapper(iterator: Iterator[V])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##(): Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  6. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  7. def mapParallel[U](numThreads: Int, threadFactory: ⇒ ThreadFactory = Executors.defaultThreadFactory())(f: (V) ⇒ U): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    U

    Type of the new values

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    threadFactory

    The thread factory used to create new threads. This can be used to add initialization code to each worker.

    f

    Mapping function, providing the new value for the element

    returns

    An iterator with mapping function applied to each element.

  8. def mapParallel[U](f: (V) ⇒ U, numThreads: Int, threadFactory: ⇒ ThreadFactory): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    U

    Type of the new values

    f

    Mapping function, providing the new value for the element

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    threadFactory

    The thread factory used to create new threads. This can be used to add initialization code to each worker.

    returns

    An iterator with mapping function applied to each element.

  9. def mapParallel[U](f: (V) ⇒ U, numThreads: Int): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    U

    Type of the new values

    f

    Mapping function, providing the new value for the element

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    returns

    An iterator with mapping function applied to each element.

  10. def mapParallelUnordered[U](numThreads: Int, threadFactory: ⇒ ThreadFactory = Executors.defaultThreadFactory())(f: (V) ⇒ U): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel. Elements are emitted as soon as they are ready, therefore it is possible that the transformed elements are not in the same order as in the input iterator.

    U

    Type of the new values

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    threadFactory

    The thread factory used to create new threads. This can be used to add initialization code to each worker.

    f

    Mapping function, providing the new value for the element

    returns

    An iterator with mapping function applied to each element.

  11. def mapParallelUnordered[U](f: (V) ⇒ U, numThreads: Int, threadFactory: ⇒ ThreadFactory): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel. Elements are emitted as soon as they are ready, therefore it is possible that the transformed elements are not in the same order as in the input iterator.

    U

    Type of the new values

    f

    Mapping function, providing the new value for the element

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    threadFactory

    The thread factory used to create new threads. This can be used to add initialization code to each worker.

    returns

    An iterator with mapping function applied to each element.

  12. def mapParallelUnordered[U](f: (V) ⇒ U, numThreads: Int): Iterator[U]

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel.

    Applies a map to an iterator, but it can use a thread pool if numThreads is >1, in that case elements are computed in parallel. Elements are emitted as soon as they are ready, therefore it is possible that the transformed elements are not in the same order as in the input iterator.

    U

    Type of the new values

    f

    Mapping function, providing the new value for the element

    numThreads

    Number of threads to use for parallel invocations of f(). Can only be set to a value larger than 1 if the operations include IO operations, or if multiple cores are available per executor.

    returns

    An iterator with mapping function applied to each element.

  13. def toString(): String
    Definition Classes
    Any

Inherited from AnyVal

Inherited from Any

Ungrouped