Class/Object

org.apache.ignite.scalar.pimps

ScalarProjectionPimp

Related Docs: object ScalarProjectionPimp | package pimps

Permalink

class ScalarProjectionPimp[A <: ClusterGroup] extends PimpedType[A] with Iterable[ClusterNode] with ScalarTaskThreadContext[A]

Overview

Defines Scalar "pimp" for GridProjection on Java side.

Essentially this class extends Java GridProjection interface with Scala specific API adapters using primarily implicit conversions defined in ScalarConversions object. What it means is that you can use functions defined in this class on object of Java GridProjection type. Scala will automatically (implicitly) convert it into Scalar's pimp and replace the original call with a call on that pimp.

Note that Scalar provide extensive library of implicit conversion between Java and Scala Ignite counterparts in ScalarConversions object

Suffix '$' In Names

Symbol $ is used in names when they conflict with the names in the base Java class that Scala pimp is shadowing or with Java package name that your Scala code is importing. Instead of giving two different names to the same function we've decided to simply mark Scala's side method with $ suffix.

Linear Supertypes
ScalarTaskThreadContext[A], ScalarConversions, Iterable[ClusterNode], IterableLike[ClusterNode, Iterable[ClusterNode]], Equals, GenIterable[ClusterNode], GenIterableLike[ClusterNode, Iterable[ClusterNode]], Traversable[ClusterNode], GenTraversable[ClusterNode], GenericTraversableTemplate[ClusterNode, Iterable], TraversableLike[ClusterNode, Iterable[ClusterNode]], GenTraversableLike[ClusterNode, Iterable[ClusterNode]], Parallelizable[ClusterNode, ParIterable[ClusterNode]], TraversableOnce[ClusterNode], GenTraversableOnce[ClusterNode], FilterMonadic[ClusterNode, Iterable[ClusterNode]], HasNewBuilder[ClusterNode, Iterable[org.apache.ignite.cluster.ClusterNode] @scala.annotation.unchecked.uncheckedVariance], PimpedType[A], AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ScalarProjectionPimp
  2. ScalarTaskThreadContext
  3. ScalarConversions
  4. Iterable
  5. IterableLike
  6. Equals
  7. GenIterable
  8. GenIterableLike
  9. Traversable
  10. GenTraversable
  11. GenericTraversableTemplate
  12. TraversableLike
  13. GenTraversableLike
  14. Parallelizable
  15. TraversableOnce
  16. GenTraversableOnce
  17. FilterMonadic
  18. HasNewBuilder
  19. PimpedType
  20. AnyRef
  21. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ScalarProjectionPimp()

    Permalink

Type Members

  1. type Call[R] = () ⇒ R

    Permalink

    Type alias for '() => R'.

    Type alias for '() => R'.

    Attributes
    protected
  2. type Call1[E1, R] = (E1) ⇒ R

    Permalink

    Type alias for '(E1) => R'.

    Type alias for '(E1) => R'.

    Attributes
    protected
  3. type Call2[E1, E2, R] = (E1, E2) ⇒ R

    Permalink

    Type alias for '(E1, E2) => R'.

    Type alias for '(E1, E2) => R'.

    Attributes
    protected
  4. type Call3[E1, E2, E3, R] = (E1, E2, E3) ⇒ R

    Permalink

    Type alias for '(E1, E2, E3) => R'.

    Type alias for '(E1, E2, E3) => R'.

    Attributes
    protected
  5. type NF = IgnitePredicate[ClusterNode]

    Permalink

    Type alias for node filter predicate.

    Type alias for node filter predicate.

    Attributes
    protected
  6. type Pred = () ⇒ Boolean

    Permalink

    Type alias for '() => Boolean'.

    Type alias for '() => Boolean'.

    Attributes
    protected
  7. type Pred1[E1] = (E1) ⇒ Boolean

    Permalink

    Type alias for '(E1) => Boolean'.

    Type alias for '(E1) => Boolean'.

    Attributes
    protected
  8. type Pred2[E1, E2] = (E1, E2) ⇒ Boolean

    Permalink

    Type alias for '(E1, E2) => Boolean'.

    Type alias for '(E1, E2) => Boolean'.

    Attributes
    protected
  9. type Pred3[E1, E2, E3] = (E1, E2, E3) ⇒ Boolean

    Permalink

    Type alias for '(E1, E2, E3) => Boolean'.

    Type alias for '(E1, E2, E3) => Boolean'.

    Attributes
    protected
  10. type Run = () ⇒ Unit

    Permalink

    Type alias for '() => Unit'.

    Type alias for '() => Unit'.

    Attributes
    protected
  11. type Self = Iterable[ClusterNode]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    TraversableLike
  12. class WithFilter extends FilterMonadic[A, Repr]

    Permalink
    Definition Classes
    TraversableLike

Value Members

  1. def !<(seq: Seq[AnyRef], p: NF): Unit

    Permalink

    Alias for method send$(...).

    Alias for method send$(...).

    seq

    Optional sequence of objects to send. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If none provided or null - all nodes in the projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.send(...)

  2. def !<(obj: AnyRef, p: NF): Unit

    Permalink

    Alias for method send$(...).

    Alias for method send$(...).

    obj

    Optional object to send. If null - this method is no-op.

    p

    Optional node filter predicates. If none provided or null - all nodes in the projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.send(...)

  3. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  5. def #<[R](s: Call[R], p: NF): Seq[R]

    Permalink

    Alias for the same function call$.

    Alias for the same function call$.

    s

    Optional closure to call. If null - this method is no-op and returns null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  6. def #<[R](s: Seq[Call[R]], p: NF): Seq[R]

    Permalink

    Alias for the same function call$.

    Alias for the same function call$.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and returns null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  7. def #?[R](s: Call[R], p: NF): IgniteFuture[Collection[R]]

    Permalink

    Alias for the same function callAsync$.

    Alias for the same function callAsync$.

    s

    Optional closure to call. If null - this method is no-op and finished future over null is returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future of Java collection containing result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  8. def #?[R](s: Seq[Call[R]], p: NF): IgniteFuture[Collection[R]]

    Permalink

    Alias for the same function callAsync$.

    Alias for the same function callAsync$.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and finished future over null is returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future of Java collection containing result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  9. def *<(s: Run, p: NF): Unit

    Permalink

    Alias for the same function run$.

    Alias for the same function run$.

    s

    Optional closure to call. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If none provided or null - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  10. def *<(s: Seq[Run], p: NF): Unit

    Permalink

    Alias alias for the same function run$.

    Alias alias for the same function run$.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  11. def *?(s: Run, p: NF): IgniteFuture[_]

    Permalink

    Alias for the same function runAsync$.

    Alias for the same function runAsync$.

    s

    Optional absolute closure to call. If null - this method is no-op and finished future over null will be returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  12. def *?(s: Seq[Run], p: NF): IgniteFuture[_]

    Permalink

    Alias for the same function runAsync$.

    Alias for the same function runAsync$.

    s

    Optional sequence of absolute closures to call. If empty or null - this method is no-op and finished future over null will be returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  13. def ++[B >: ClusterNode, That](that: GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  14. def ++:[B >: ClusterNode, That](that: Traversable[B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike
  15. def ++:[B >: ClusterNode, That](that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike
  16. def /:[B](z: B)(op: (B, ClusterNode) ⇒ B): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  17. def :\[B](z: B)(op: (ClusterNode, B) ⇒ B): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  18. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  19. def @<[R1, R2](s: Seq[Call[R1]], r: (Seq[R1]) ⇒ R2, p: NF): R2

    Permalink

    Alias for the same function reduce$.

    Alias for the same function reduce$.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and will return null.

    r

    Optional reduction function. If null - this method is no-op and will return null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Reduced result or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.reduce(...)

  20. def @?[R1, R2](s: Seq[Call[R1]], r: (Seq[R1]) ⇒ R2, p: NF): IgniteFuture[R2]

    Permalink

    Alias for the same function reduceAsync$.

    Alias for the same function reduceAsync$.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and will return finished future over null.

    r

    Optional reduction function. If null - this method is no-op and will return finished future over null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future over the reduced result or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.reduce(...)

  21. implicit def absClosureDotScala(f: GridAbsClosure): AnyRef { def scala: () => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side absolute closure to pimp.

    Definition Classes
    ScalarConversions
  22. implicit def absClosureXDotScala(f: GridAbsClosureX): AnyRef { def scala: () => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side absolute closure to pimp.

    Definition Classes
    ScalarConversions
  23. implicit def absPredicateDotScala(p: GridAbsPredicate): AnyRef { def scala: () => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  24. implicit def absPredicateXDotScala(p: GridAbsPredicateX): AnyRef { def scala: () => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  25. def addString(b: StringBuilder): StringBuilder

    Permalink
    Definition Classes
    TraversableOnce
  26. def addString(b: StringBuilder, sep: String): StringBuilder

    Permalink
    Definition Classes
    TraversableOnce
  27. def addString(b: StringBuilder, start: String, sep: String, end: String): StringBuilder

    Permalink
    Definition Classes
    TraversableOnce
  28. def affinityRun$(cacheName: String, affKey: Any, r: Run, p: NF): Unit

    Permalink

    Executes given closure on the nodes where data for provided affinity key is located.

    Executes given closure on the nodes where data for provided affinity key is located. This is known as affinity co-location between compute grid (a closure) and in-memory data grid (value with affinity key). Note that implementation of multiple executions of the same closure will be wrapped as a single task that splits into multiple jobs that will be mapped to nodes with provided affinity keys.

    This method will block until its execution is complete or an exception is thrown. All default SPI implementations configured for this grid instance will be used (i.e. failover, load balancing, collision resolution, etc.). Note that if you need greater control on any aspects of Java code execution on the grid you should implement ComputeTask which will provide you with full control over the execution.

    Notice that Runnable and Callable implementations must support serialization as required by the configured marshaller. For example, JDK marshaller will require that implementations would be serializable. Other marshallers, e.g. JBoss marshaller, may not have this limitation. Please consult with specific marshaller implementation for the details. Note that all closures and predicates in org.apache.ignite.lang package are serializable and can be freely used in the distributed context with all marshallers currently shipped with Ignite.

    cacheName

    Name of the cache to use for affinity co-location.

    affKey

    Affinity key.

    r

    Closure to affinity co-located on the node with given affinity key and execute. If null - this method is no-op.

    p

    Optional filtering predicate. If null provided - all nodes in this projection will be used for topology.

    Exceptions thrown

    ClusterGroupEmptyException Thrown in case when this projection is empty. Note that in case of dynamic projection this method will take a snapshot of all the nodes at the time of this call, apply all filtering predicates, if any, and if the resulting collection of nodes is empty - the exception will be thrown.

    IgniteCheckedException Thrown in case of any error.

    IgniteFutureCancelledException Subclass of IgniteException thrown if computation was cancelled.

    IgniteInterruptedException Subclass of IgniteException thrown if the wait was interrupted.

  29. def affinityRunAsync$(cacheName: String, affKey: Any, r: Run, p: NF): IgniteFuture[_]

    Permalink

    Executes given closure on the nodes where data for provided affinity key is located.

    Executes given closure on the nodes where data for provided affinity key is located. This is known as affinity co-location between compute grid (a closure) and in-memory data grid (value with affinity key). Note that implementation of multiple executions of the same closure will be wrapped as a single task that splits into multiple jobs that will be mapped to nodes with provided affinity keys.

    Unlike its sibling method affinityRun(String, Collection, Runnable, GridPredicate[]) this method does not block and returns immediately with future. All default SPI implementations configured for this grid instance will be used (i.e. failover, load balancing, collision resolution, etc.). Note that if you need greater control on any aspects of Java code execution on the grid you should implement ComputeTask which will provide you with full control over the execution.

    Note that class GridAbsClosure implements Runnable and class GridOutClosure implements Callable interface. Note also that class GridFunc and typedefs provide rich APIs and functionality for closures and predicates based processing in Ignite. While Java interfaces Runnable and Callable allow for lowest common denominator for APIs - it is advisable to use richer Functional Programming support provided by Ignite available in org.apache.ignite.lang package.

    Notice that Runnable and Callable implementations must support serialization as required by the configured marshaller. For example, JDK marshaller will require that implementations would be serializable. Other marshallers, e.g. JBoss marshaller, may not have this limitation. Please consult with specific marshaller implementation for the details. Note that all closures and predicates in org.apache.ignite.lang package are serializable and can be freely used in the distributed context with all marshallers currently shipped with Ignite.

    cacheName

    Name of the cache to use for affinity co-location.

    affKey

    Affinity key.

    r

    Closure to affinity co-located on the node with given affinity key and execute. If null - this method is no-op.

    p

    Optional filtering predicate. If null provided - all nodes in this projection will be used for topology.

    returns

    Non-cancellable future of this execution.

    Exceptions thrown

    ClusterGroupEmptyCheckedException Thrown in case when this projection is empty. Note that in case of dynamic projection this method will take a snapshot of all the nodes at the time of this call, apply all filtering predicates, if any, and if the resulting collection of nodes is empty - the exception will be thrown.

    IgniteCheckedException Thrown in case of any error.

    IgniteFutureCancelledException Subclass of IgniteException thrown if computation was cancelled.

    IgniteInterruptedException Subclass of IgniteException thrown if the wait was interrupted.

  30. def aggregate[B](z: ⇒ B)(seqop: (B, ClusterNode) ⇒ B, combop: (B, B) ⇒ B): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  31. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  32. def bcastRun(r: Run, p: NF): Unit

    Permalink

    Synchronous broadcast closure call on this projection without return value.

    Synchronous broadcast closure call on this projection without return value.

    r

    Closure to run all nodes in projection.

    p

    Optional node filter predicate. If null provided- all nodes in projection will be used.

  33. def call$[R](s: Call[R], p: NF): Seq[R]

    Permalink

    Synchronous closure call on this projection with return value.

    Synchronous closure call on this projection with return value. This call will block until all results are received and ready.

    s

    Optional closure to call. If null - this method is no-op and returns null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  34. def call$[R](s: Seq[Call[R]], p: NF): Seq[R]

    Permalink

    Synchronous closures call on this projection with return value.

    Synchronous closures call on this projection with return value. This call will block until all results are received and ready.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and returns null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

  35. def callAsync$[R](s: Call[R], p: NF): IgniteFuture[Collection[R]]

    Permalink

    Asynchronous closure call on this projection with return value.

    Asynchronous closure call on this projection with return value. This call will return immediately with the future that can be used to wait asynchronously for the results.

    s

    Optional closure to call. If null - this method is no-op and finished future over null is returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future of Java collection containing result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  36. def callAsync$[R](s: Seq[Call[R]], p: NF): IgniteFuture[Collection[R]]

    Permalink

    Asynchronous closures call on this projection with return value.

    Asynchronous closures call on this projection with return value. This call will return immediately with the future that can be used to wait asynchronously for the results.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and finished future over null is returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future of Java collection containing result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  37. def callSafe[R](s: Call[R], dflt: () ⇒ Seq[R], p: NF): Seq[R]

    Permalink

    Synchronous closure call on this projection with return value.

    Synchronous closure call on this projection with return value. This call will block until all results are received and ready. If this projection is empty than dflt closure will be executed and its result returned.

    s

    Optional closure to call. If null - this method is no-op and returns null.

    dflt

    Closure to execute if projection is empty.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  38. def callSafe[R](s: Seq[Call[R]], dflt: () ⇒ Seq[R], p: NF): Seq[R]

    Permalink

    Synchronous closures call on this projection with return value.

    Synchronous closures call on this projection with return value. This call will block until all results are received and ready. If this projection is empty than dflt closure will be executed and its result returned.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and returns null.

    dflt

    Closure to execute if projection is empty.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Sequence of result values from all nodes where given closures were executed or null (see above).

  39. def canEqual(that: Any): Boolean

    Permalink
    Definition Classes
    IterableLike → Equals
  40. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  41. implicit def closure2DotScala[A1, A2, R](f: IgniteBiClosure[A1, A2, R]): AnyRef { def scala: (A1, A2) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  42. implicit def closure2XDotScala[A1, A2, R](f: IgniteClosure2X[A1, A2, R]): AnyRef { def scala: (A1, A2) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  43. implicit def closure3DotScala[A1, A2, A3, R](f: GridClosure3[A1, A2, A3, R]): AnyRef { def scala: (A1, A2, A3) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  44. implicit def closure3XDotScala[A1, A2, A3, R](f: GridClosure3X[A1, A2, A3, R]): AnyRef { def scala: (A1, A2, A3) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  45. implicit def closureDotScala[A, R](f: IgniteClosure[A, R]): AnyRef { def scala: A => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  46. implicit def closureXDotScala[A, R](f: IgniteClosureX[A, R]): AnyRef { def scala: A => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  47. def collect[B, That](pf: PartialFunction[ClusterNode, B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  48. def collectFirst[B](pf: PartialFunction[ClusterNode, B]): Option[B]

    Permalink
    Definition Classes
    TraversableOnce
  49. def companion: GenericCompanion[Iterable]

    Permalink
    Definition Classes
    Iterable → GenIterable → Traversable → GenTraversable → GenericTraversableTemplate
  50. def copyToArray[B >: ClusterNode](xs: Array[B], start: Int, len: Int): Unit

    Permalink
    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce
  51. def copyToArray[B >: ClusterNode](xs: Array[B]): Unit

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  52. def copyToArray[B >: ClusterNode](xs: Array[B], start: Int): Unit

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  53. def copyToBuffer[B >: ClusterNode](dest: Buffer[B]): Unit

    Permalink
    Definition Classes
    TraversableOnce
  54. def count(p: (ClusterNode) ⇒ Boolean): Int

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  55. def drop(n: Int): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike
  56. def dropRight(n: Int): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike
  57. def dropWhile(p: (ClusterNode) ⇒ Boolean): Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  58. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  59. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  60. def exists(p: (ClusterNode) ⇒ Boolean): Boolean

    Permalink
    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce
  61. def filter(p: (ClusterNode) ⇒ Boolean): Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  62. def filterNot(p: (ClusterNode) ⇒ Boolean): Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  63. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  64. def find(p: (ClusterNode) ⇒ Boolean): Option[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce
  65. def flatMap[B, That](f: (ClusterNode) ⇒ GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike → FilterMonadic
  66. def flatten[B](implicit asTraversable: (ClusterNode) ⇒ GenTraversableOnce[B]): Iterable[B]

    Permalink
    Definition Classes
    GenericTraversableTemplate
  67. def fold[A1 >: ClusterNode](z: A1)(op: (A1, A1) ⇒ A1): A1

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  68. def foldLeft[B](z: B)(op: (B, ClusterNode) ⇒ B): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  69. def foldRight[B](z: B)(op: (ClusterNode, B) ⇒ B): B

    Permalink
    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce
  70. def forall(p: (ClusterNode) ⇒ Boolean): Boolean

    Permalink
    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce
  71. def foreach[U](f: (ClusterNode) ⇒ U): Unit

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike → TraversableOnce → GenTraversableOnce → FilterMonadic
  72. implicit def fromAbsClosure(f: GridAbsClosure): () ⇒ Unit

    Permalink

    Implicit converter from GridAbsClosure to Scala wrapping function.

    Implicit converter from GridAbsClosure to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  73. implicit def fromAbsClosureX(f: GridAbsClosureX): () ⇒ Unit

    Permalink

    Implicit converter from GridAbsClosureX to Scala wrapping function.

    Implicit converter from GridAbsClosureX to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  74. implicit def fromAbsPredicate(p: GridAbsPredicate): () ⇒ Boolean

    Permalink

    Implicit converter from GridAbsPredicate to Scala wrapping predicate.

    Implicit converter from GridAbsPredicate to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  75. implicit def fromAbsPredicateX(p: GridAbsPredicateX): () ⇒ Boolean

    Permalink

    Implicit converter from GridAbsPredicateX to Scala wrapping predicate.

    Implicit converter from GridAbsPredicateX to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  76. implicit def fromClosure[A, R](f: IgniteClosure[A, R]): (A) ⇒ R

    Permalink

    Implicit converter from GridClosure to Scala wrapping closure.

    Implicit converter from GridClosure to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  77. implicit def fromClosure2[A1, A2, R](f: IgniteBiClosure[A1, A2, R]): (A1, A2) ⇒ R

    Permalink

    Implicit converter from GridClosure2X to Scala wrapping closure.

    Implicit converter from GridClosure2X to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  78. implicit def fromClosure2X[A1, A2, R](f: IgniteClosure2X[A1, A2, R]): (A1, A2) ⇒ R

    Permalink

    Implicit converter from GridClosure2X to Scala wrapping closure.

    Implicit converter from GridClosure2X to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  79. implicit def fromClosure3[A1, A2, A3, R](f: GridClosure3[A1, A2, A3, R]): (A1, A2, A3) ⇒ R

    Permalink

    Implicit converter from GridClosure3 to Scala wrapping closure.

    Implicit converter from GridClosure3 to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  80. implicit def fromClosure3X[A1, A2, A3, R](f: GridClosure3X[A1, A2, A3, R]): (A1, A2, A3) ⇒ R

    Permalink

    Implicit converter from GridClosure3X to Scala wrapping closure.

    Implicit converter from GridClosure3X to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  81. implicit def fromClosureX[A, R](f: IgniteClosureX[A, R]): (A) ⇒ R

    Permalink

    Implicit converter from GridClosureX to Scala wrapping closure.

    Implicit converter from GridClosureX to Scala wrapping closure.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  82. implicit def fromInClosure[T](f: IgniteInClosure[T]): (T) ⇒ Unit

    Permalink

    Implicit converter from GridInClosure to Scala wrapping function.

    Implicit converter from GridInClosure to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  83. implicit def fromInClosure2[T1, T2](f: IgniteBiInClosure[T1, T2]): (T1, T2) ⇒ Unit

    Permalink

    Implicit converter from GridInClosure2 to Scala wrapping function.

    Implicit converter from GridInClosure2 to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  84. implicit def fromInClosure2X[T1, T2](f: IgniteInClosure2X[T1, T2]): (T1, T2) ⇒ Unit

    Permalink

    Implicit converter from GridInClosure2X to Scala wrapping function.

    Implicit converter from GridInClosure2X to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  85. implicit def fromInClosure3[T1, T2, T3](f: GridInClosure3[T1, T2, T3]): (T1, T2, T3) ⇒ Unit

    Permalink

    Implicit converter from GridInClosure3 to Scala wrapping function.

    Implicit converter from GridInClosure3 to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  86. implicit def fromInClosure3X[T1, T2, T3](f: GridInClosure3X[T1, T2, T3]): (T1, T2, T3) ⇒ Unit

    Permalink

    Implicit converter from GridInClosure3X to Scala wrapping function.

    Implicit converter from GridInClosure3X to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  87. implicit def fromInClosureX[T](f: IgniteInClosureX[T]): (T) ⇒ Unit

    Permalink

    Implicit converter from GridInClosureX to Scala wrapping function.

    Implicit converter from GridInClosureX to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  88. implicit def fromOutClosure[R](f: IgniteCallable[R]): () ⇒ R

    Permalink

    Implicit converter from GridOutClosure to Scala wrapping function.

    Implicit converter from GridOutClosure to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  89. implicit def fromOutClosureX[R](f: IgniteOutClosureX[R]): () ⇒ R

    Permalink

    Implicit converter from GridOutClosureX to Scala wrapping function.

    Implicit converter from GridOutClosureX to Scala wrapping function.

    f

    Grid closure to convert.

    Definition Classes
    ScalarConversions
  90. implicit def fromPredicate[T](p: IgnitePredicate[T]): (T) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate to Scala wrapping predicate.

    Implicit converter from GridPredicate to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  91. implicit def fromPredicate2[T1, T2](p: IgniteBiPredicate[T1, T2]): (T1, T2) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate2X to Scala wrapping predicate.

    Implicit converter from GridPredicate2X to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  92. implicit def fromPredicate2X[T1, T2](p: IgnitePredicate2X[T1, T2]): (T1, T2) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate2X to Scala wrapping predicate.

    Implicit converter from GridPredicate2X to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  93. implicit def fromPredicate3[T1, T2, T3](p: GridPredicate3[T1, T2, T3]): (T1, T2, T3) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate3X to Scala wrapping predicate.

    Implicit converter from GridPredicate3X to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  94. implicit def fromPredicate3X[T1, T2, T3](p: GridPredicate3X[T1, T2, T3]): (T1, T2, T3) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate3X to Scala wrapping predicate.

    Implicit converter from GridPredicate3X to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  95. implicit def fromPredicateX[T](p: IgnitePredicateX[T]): (T) ⇒ Boolean

    Permalink

    Implicit converter from GridPredicate to Scala wrapping predicate.

    Implicit converter from GridPredicate to Scala wrapping predicate.

    p

    Grid predicate to convert.

    Definition Classes
    ScalarConversions
  96. implicit def fromReducer[E, R](r: IgniteReducer[E, R]): (Seq[E]) ⇒ R

    Permalink

    Implicit converter from Java GridReducer to Scala function.

    Implicit converter from Java GridReducer to Scala function.

    r

    Java GridReducer to convert.

    Definition Classes
    ScalarConversions
  97. implicit def fromReducer2[E1, E2, R](r: IgniteReducer2[E1, E2, R]): (Seq[E1], Seq[E2]) ⇒ R

    Permalink

    Implicit converter from Java GridReducer2 to Scala function.

    Implicit converter from Java GridReducer2 to Scala function.

    r

    Java GridReducer2 to convert.

    Definition Classes
    ScalarConversions
  98. implicit def fromReducer3[E1, E2, E3, R](r: IgniteReducer3[E1, E2, E3, R]): (Seq[E1], Seq[E2], Seq[E3]) ⇒ R

    Permalink

    Implicit converter from Java GridReducer3 to Scala function.

    Implicit converter from Java GridReducer3 to Scala function.

    r

    Java GridReducer3 to convert.

    Definition Classes
    ScalarConversions
  99. implicit def fromSymbol(s: Symbol): String

    Permalink

    Converts from Symbol to String.

    Converts from Symbol to String.

    s

    Symbol to convert.

    Definition Classes
    ScalarConversions
  100. implicit def fromTuple2[A, B](t: IgniteBiTuple[A, B]): (A, B)

    Permalink

    Implicit converter from GridTuple2 to Scala tuple.

    Implicit converter from GridTuple2 to Scala tuple.

    t

    GridTuple2 to convert.

    Definition Classes
    ScalarConversions
  101. implicit def fromTuple3[A, B, C](t: GridTuple3[A, B, C]): (A, B, C)

    Permalink

    Implicit converter from GridTuple3 to Scala tuple.

    Implicit converter from GridTuple3 to Scala tuple.

    t

    GridTuple3 to convert.

    Definition Classes
    ScalarConversions
  102. implicit def fromTuple4[A, B, C, D](t: GridTuple4[A, B, C, D]): (A, B, C, D)

    Permalink

    Implicit converter from GridTuple4 to Scala tuple.

    Implicit converter from GridTuple4 to Scala tuple.

    t

    GridTuple4 to convert.

    Definition Classes
    ScalarConversions
  103. implicit def fromTuple5[A, B, C, D, E](t: GridTuple5[A, B, C, D, E]): (A, B, C, D, E)

    Permalink

    Implicit converter from GridTuple5 to Scala tuple.

    Implicit converter from GridTuple5 to Scala tuple.

    t

    GridTuple5 to convert.

    Definition Classes
    ScalarConversions
  104. def genericBuilder[B]: Builder[B, Iterable[B]]

    Permalink
    Definition Classes
    GenericTraversableTemplate
  105. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  106. def groupBy[K](f: (ClusterNode) ⇒ K): Map[K, Iterable[ClusterNode]]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  107. def grouped(size: Int): Iterator[Iterable[ClusterNode]]

    Permalink
    Definition Classes
    IterableLike
  108. def hasDefiniteSize: Boolean

    Permalink
    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce
  109. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  110. def head: ClusterNode

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike
  111. def headOption: Option[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  112. var impl: A

    Permalink

    Attributes
    protected
  113. implicit def inClosure2DotScala[T1, T2](f: IgniteBiInClosure[T1, T2]): AnyRef { def scala: (T1, T2) => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  114. implicit def inClosure2XDotScala[T1, T2](f: IgniteInClosure2X[T1, T2]): AnyRef { def scala: (T1, T2) => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  115. implicit def inClosure3DotScala[T1, T2, T3](f: GridInClosure3[T1, T2, T3]): AnyRef { def scala: (T1, T2, T3) => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  116. implicit def inClosure3XDotScala[T1, T2, T3](f: GridInClosure3X[T1, T2, T3]): AnyRef { def scala: (T1, T2, T3) => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  117. implicit def inClosureDotScala[T](f: IgniteInClosure[T]): AnyRef { def scala: T => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  118. implicit def inClosureXDotScala[T](f: IgniteInClosureX[T]): AnyRef { def scala: T => Unit }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  119. def init: Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  120. def inits: Iterator[Iterable[ClusterNode]]

    Permalink
    Definition Classes
    TraversableLike
  121. def isEmpty: Boolean

    Permalink
    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce
  122. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  123. final def isTraversableAgain: Boolean

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike → GenTraversableOnce
  124. def iterator: Iterator[ClusterNode]

    Permalink

    Gets iterator for this projection's nodes.

    Gets iterator for this projection's nodes.

    Definition Classes
    ScalarProjectionPimp → IterableLike → GenIterableLike
  125. def last: ClusterNode

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  126. def lastOption: Option[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  127. def map[B, That](f: (ClusterNode) ⇒ B)(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike → FilterMonadic
  128. def max[B >: ClusterNode](implicit cmp: Ordering[B]): ClusterNode

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  129. def maxBy[B](f: (ClusterNode) ⇒ B)(implicit cmp: Ordering[B]): ClusterNode

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  130. def min[B >: ClusterNode](implicit cmp: Ordering[B]): ClusterNode

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  131. def minBy[B](f: (ClusterNode) ⇒ B)(implicit cmp: Ordering[B]): ClusterNode

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  132. def mkString: String

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  133. def mkString(sep: String): String

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  134. def mkString(start: String, sep: String, end: String): String

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  135. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  136. def newBuilder: Builder[ClusterNode, Iterable[ClusterNode]]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    GenericTraversableTemplate → HasNewBuilder
  137. def nodes$(p: NF): Seq[ClusterNode]

    Permalink

    Gets sequence of all nodes in this projection for given predicate.

    Gets sequence of all nodes in this projection for given predicate.

    p

    Optional node filter predicates. It null provided - all nodes will be returned.

    See also

    org.apache.ignite.cluster.ClusterGroup.nodes(...)

  138. def nonEmpty: Boolean

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  139. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  140. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  141. implicit def outClosureDotScala[R](f: IgniteCallable[R]): AnyRef { def scala: () => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  142. implicit def outClosureXDotScala[R](f: IgniteOutClosureX[R]): AnyRef { def scala: () => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    f

    Java-side closure to pimp.

    Definition Classes
    ScalarConversions
  143. def par: ParIterable[ClusterNode]

    Permalink
    Definition Classes
    Parallelizable
  144. def parCombiner: Combiner[ClusterNode, ParIterable[ClusterNode]]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    TraversableLike → Parallelizable
  145. def partition(p: (ClusterNode) ⇒ Boolean): (Iterable[ClusterNode], Iterable[ClusterNode])

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  146. implicit def predicate2DotScala[T1, T2](p: IgniteBiPredicate[T1, T2]): AnyRef { def scala: (T1, T2) => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  147. implicit def predicate2XDotScala[T1, T2](p: IgnitePredicate2X[T1, T2]): AnyRef { def scala: (T1, T2) => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  148. implicit def predicate3DotScala[T1, T2, T3](p: GridPredicate3[T1, T2, T3]): AnyRef { def scala: (T1, T2, T3) => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  149. implicit def predicate3XDotScala[T1, T2, T3](p: GridPredicate3X[T1, T2, T3]): AnyRef { def scala: (T1, T2, T3) => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  150. implicit def predicateDotScala[T](p: IgnitePredicate[T]): AnyRef { def scala: T => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  151. implicit def predicateXDotScala[T](p: IgnitePredicateX[T]): AnyRef { def scala: T => Boolean }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    p

    Java-side predicate to pimp.

    Definition Classes
    ScalarConversions
  152. def product[B >: ClusterNode](implicit num: Numeric[B]): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  153. def reduce[A1 >: ClusterNode](op: (A1, A1) ⇒ A1): A1

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  154. def reduce$[R1, R2](s: Seq[Call[R1]], r: (Seq[R1]) ⇒ R2, p: NF): R2

    Permalink

    Synchronous closures execution on this projection with reduction.

    Synchronous closures execution on this projection with reduction. This call will block until all results are reduced.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and will return null.

    r

    Optional reduction function. If null - this method is no-op and will return null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Reduced result or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.reduce(...)

  155. def reduceAsync$[R1, R2](s: Seq[Call[R1]], r: (Seq[R1]) ⇒ R2, p: NF): IgniteFuture[R2]

    Permalink

    Asynchronous closures execution on this projection with reduction.

    Asynchronous closures execution on this projection with reduction. This call will return immediately with the future that can be used to wait asynchronously for the results.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and will return finished future over null.

    r

    Optional reduction function. If null - this method is no-op and will return finished future over null.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Future over the reduced result or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.reduce(...)

  156. def reduceLeft[B >: ClusterNode](op: (B, ClusterNode) ⇒ B): B

    Permalink
    Definition Classes
    TraversableOnce
  157. def reduceLeftOption[B >: ClusterNode](op: (B, ClusterNode) ⇒ B): Option[B]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  158. def reduceOption[A1 >: ClusterNode](op: (A1, A1) ⇒ A1): Option[A1]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  159. def reduceRight[B >: ClusterNode](op: (ClusterNode, B) ⇒ B): B

    Permalink
    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce
  160. def reduceRightOption[B >: ClusterNode](op: (ClusterNode, B) ⇒ B): Option[B]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  161. def reduceSafe[R1, R2](s: Seq[Call[R1]], r: (Seq[R1]) ⇒ R2, dflt: () ⇒ R2, p: NF): R2

    Permalink

    Synchronous closures execution on this projection with reduction.

    Synchronous closures execution on this projection with reduction. This call will block until all results are reduced. If this projection is empty than dflt closure will be executed and its result returned.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op and will return null.

    r

    Optional reduction function. If null - this method is no-op and will return null.

    dflt

    Closure to execute if projection is empty.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    returns

    Reduced result or null (see above).

    See also

    org.apache.ignite.cluster.ClusterGroup.reduce(...)

  162. implicit def reducer2DotScala[E1, E2, R](r: IgniteReducer2[E1, E2, R]): AnyRef { def scala: (Seq[E1], Seq[E2]) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    r

    Java-side reducer to pimp.

    Definition Classes
    ScalarConversions
  163. implicit def reducer3DotScala[E1, E2, E3, R](r: IgniteReducer3[E1, E2, E3, R]): AnyRef { def scala: (Seq[E1], Seq[E2], Seq[E3]) => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    r

    Java-side reducer to pimp.

    Definition Classes
    ScalarConversions
  164. implicit def reducerDotScala[E, R](r: IgniteReducer[E, R]): AnyRef { def scala: Seq[E] => R }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    r

    Java-side reducer to pimp.

    Definition Classes
    ScalarConversions
  165. def remoteNodes$(p: NF = null): Seq[ClusterNode]

    Permalink

    Gets sequence of all remote nodes in this projection for given predicate.

    Gets sequence of all remote nodes in this projection for given predicate.

    p

    Optional node filter predicate. It null provided - all remote nodes will be returned.

    See also

    org.apache.ignite.cluster.ClusterGroup.remoteNodes(...)

  166. def repr: Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  167. def reversed: List[ClusterNode]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    TraversableOnce
  168. def run$(s: Run, p: NF): Unit

    Permalink

    Synchronous closure call on this projection without return value.

    Synchronous closure call on this projection without return value. This call will block until all executions are complete.

    s

    Optional closure to call. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  169. def run$(s: Seq[Run], p: NF): Unit

    Permalink

    Synchronous closures call on this projection without return value.

    Synchronous closures call on this projection without return value. This call will block until all executions are complete.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If null provided- all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  170. def runAsync$(s: Run, p: NF): IgniteFuture[_]

    Permalink

    Asynchronous closure call on this projection without return value.

    Asynchronous closure call on this projection without return value. This call will return immediately with the future that can be used to wait asynchronously for the results.

    s

    Optional absolute closure to call. If null - this method is no-op and finished future over null will be returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  171. def runAsync$(s: Seq[Run], p: NF): IgniteFuture[_]

    Permalink

    Asynchronous closures call on this projection without return value.

    Asynchronous closures call on this projection without return value. This call will return immediately with the future that can be used to wait asynchronously for the results.

    s

    Optional sequence of absolute closures to call. If empty or null - this method is no-op and finished future over null will be returned.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.call(...)

  172. def runSafe(s: Run, dflt: Run, p: NF): Unit

    Permalink

    Synchronous closure call on this projection without return value.

    Synchronous closure call on this projection without return value. This call will block until all executions are complete. If this projection is empty than dflt closure will be executed.

    s

    Optional closure to call. If empty or null - this method is no-op.

    dflt

    Closure to execute if projection is empty.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  173. def runSafe(s: Seq[Run], dflt: Run, p: NF): Unit

    Permalink

    Synchronous closures call on this projection without return value.

    Synchronous closures call on this projection without return value. This call will block until all executions are complete. If this projection is empty than dflt closure will be executed.

    s

    Optional sequence of closures to call. If empty or null - this method is no-op.

    dflt

    Closure to execute if projection is empty.

    p

    Optional node filter predicate. If null provided - all nodes in projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.run(...)

  174. def sameElements[B >: ClusterNode](that: GenIterable[B]): Boolean

    Permalink
    Definition Classes
    IterableLike → GenIterableLike
  175. def scan[B >: ClusterNode, That](z: B)(op: (B, B) ⇒ B)(implicit cbf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  176. def scanLeft[B, That](z: B)(op: (B, ClusterNode) ⇒ B)(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  177. def scanRight[B, That](z: B)(op: (ClusterNode, B) ⇒ B)(implicit bf: CanBuildFrom[Iterable[ClusterNode], B, That]): That

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
    Annotations
    @migration
    Migration

    (Changed in version 2.9.0) The behavior of scanRight has changed. The previous behavior can be reproduced with scanRight.reverse.

  178. def send$(seq: Seq[AnyRef], p: NF): Unit

    Permalink

    Sends given object to the nodes in this projection.

    Sends given object to the nodes in this projection.

    seq

    Optional sequence of objects to send. If empty or null - this method is no-op.

    p

    Optional node filter predicate. If null provided - all nodes in the projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.send(...)

  179. def send$(obj: AnyRef, p: NF): Unit

    Permalink

    Sends given object to the nodes in this projection.

    Sends given object to the nodes in this projection.

    obj

    Optional object to send. If null - this method is no-op.

    p

    Optional node filter predicate. If none provided or null - all nodes in the projection will be used.

    See also

    org.apache.ignite.cluster.ClusterGroup.send(...)

  180. def seq: Iterable[ClusterNode]

    Permalink
    Definition Classes
    Iterable → GenIterable → Traversable → GenTraversable → Parallelizable → TraversableOnce → GenTraversableOnce
  181. def size: Int

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  182. def slice(from: Int, until: Int): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike
  183. def sliding(size: Int, step: Int): Iterator[Iterable[ClusterNode]]

    Permalink
    Definition Classes
    IterableLike
  184. def sliding(size: Int): Iterator[Iterable[ClusterNode]]

    Permalink
    Definition Classes
    IterableLike
  185. def span(p: (ClusterNode) ⇒ Boolean): (Iterable[ClusterNode], Iterable[ClusterNode])

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  186. def splitAt(n: Int): (Iterable[ClusterNode], Iterable[ClusterNode])

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  187. def stringPrefix: String

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  188. def sum[B >: ClusterNode](implicit num: Numeric[B]): B

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  189. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  190. def tail: Iterable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → GenTraversableLike
  191. def tails: Iterator[Iterable[ClusterNode]]

    Permalink
    Definition Classes
    TraversableLike
  192. def take(n: Int): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike
  193. def takeRight(n: Int): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike
  194. def takeWhile(p: (ClusterNode) ⇒ Boolean): Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike
  195. def thisCollection: Iterable[ClusterNode]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    IterableLike → TraversableLike
  196. def timerTask(f: ⇒ Unit): TimerTask

    Permalink

    Explicit converter for TimerTask.

    Explicit converter for TimerTask. Note that since TimerTask implements Runnable we can't use the implicit conversion.

    f

    Closure to convert.

    returns

    Time task instance.

    Definition Classes
    ScalarConversions
  197. def to[Col[_]](implicit cbf: CanBuildFrom[Nothing, ClusterNode, Col[ClusterNode]]): Col[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce
  198. implicit def toAbsClosure2(r: Runnable): GridAbsClosure

    Permalink

    Implicit converter from java.lang.Runnable to GridAbsClosure.

    Implicit converter from java.lang.Runnable to GridAbsClosure.

    r

    Java runnable to convert.

    Definition Classes
    ScalarConversions
  199. def toAbsClosureX(f: () ⇒ Unit): GridAbsClosureX

    Permalink

    Implicit converter from Scala function to GridAbsClosureX.

    Implicit converter from Scala function to GridAbsClosureX.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  200. implicit def toAbsPredicate(f: () ⇒ Boolean): GridAbsPredicate

    Permalink

    Implicit converter from Scala predicate to GridAbsPredicate.

    Implicit converter from Scala predicate to GridAbsPredicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  201. implicit def toAbsPredicateX(f: () ⇒ Boolean): GridAbsPredicateX

    Permalink

    Implicit converter from Scala predicate to GridAbsPredicateX.

    Implicit converter from Scala predicate to GridAbsPredicateX.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  202. def toArray[B >: ClusterNode](implicit arg0: ClassTag[B]): Array[B]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  203. def toBuffer[B >: ClusterNode]: Buffer[B]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  204. implicit def toCallable[R](f: () ⇒ R): IgniteCallable[R]

    Permalink

    Implicit converter from Scala function to GridOutClosure.

    Implicit converter from Scala function to GridOutClosure.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  205. implicit def toClosure[A, R](f: (A) ⇒ R): IgniteClosure[A, R]

    Permalink

    Implicit converter from Scala closure to GridClosure.

    Implicit converter from Scala closure to GridClosure.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  206. implicit def toClosure2[A1, A2, R](f: (A1, A2) ⇒ R): IgniteBiClosure[A1, A2, R]

    Permalink

    Implicit converter from Scala closure to GridClosure2.

    Implicit converter from Scala closure to GridClosure2.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  207. def toClosure2X[A1, A2, R](f: (A1, A2) ⇒ R): IgniteClosure2X[A1, A2, R]

    Permalink

    Implicit converter from Scala closure to GridClosure2X.

    Implicit converter from Scala closure to GridClosure2X.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  208. implicit def toClosure3[A1, A2, A3, R](f: (A1, A2, A3) ⇒ R): GridClosure3[A1, A2, A3, R]

    Permalink

    Implicit converter from Scala closure to GridClosure3X.

    Implicit converter from Scala closure to GridClosure3X.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  209. def toClosure3X[A1, A2, A3, R](f: (A1, A2, A3) ⇒ R): GridClosure3X[A1, A2, A3, R]

    Permalink

    Implicit converter from Scala closure to GridClosure3X.

    Implicit converter from Scala closure to GridClosure3X.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  210. def toClosureX[A, R](f: (A) ⇒ R): IgniteClosureX[A, R]

    Permalink

    Implicit converter from Scala closure to GridClosureX.

    Implicit converter from Scala closure to GridClosureX.

    f

    Scala closure to convert.

    Definition Classes
    ScalarConversions
  211. def toCollection(repr: Iterable[ClusterNode]): Iterable[ClusterNode]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    IterableLike → TraversableLike
  212. implicit def toInClosure[T](f: (T) ⇒ Unit): IgniteInClosure[T]

    Permalink

    Implicit converter from Scala function to GridInClosure.

    Implicit converter from Scala function to GridInClosure.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  213. implicit def toInClosure2[T1, T2](f: (T1, T2) ⇒ Unit): IgniteBiInClosure[T1, T2]

    Permalink

    Implicit converter from Scala function to GridInClosure2.

    Implicit converter from Scala function to GridInClosure2.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  214. implicit def toInClosure2X[T1, T2](f: (T1, T2) ⇒ Unit): IgniteInClosure2X[T1, T2]

    Permalink

    Implicit converter from Scala function to GridInClosure2X.

    Implicit converter from Scala function to GridInClosure2X.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  215. implicit def toInClosure3[T1, T2, T3](f: (T1, T2, T3) ⇒ Unit): GridInClosure3[T1, T2, T3]

    Permalink

    Implicit converter from Scala function to GridInClosure3.

    Implicit converter from Scala function to GridInClosure3.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  216. def toInClosure3X[T1, T2, T3](f: (T1, T2, T3) ⇒ Unit): GridInClosure3X[T1, T2, T3]

    Permalink

    Implicit converter from Scala function to GridInClosure3X.

    Implicit converter from Scala function to GridInClosure3X.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  217. def toInClosureX[T](f: (T) ⇒ Unit): IgniteInClosureX[T]

    Permalink

    Implicit converter from Scala function to GridInClosureX.

    Implicit converter from Scala function to GridInClosureX.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  218. def toIndexedSeq: IndexedSeq[ClusterNode]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  219. def toIterable: Iterable[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce
  220. def toIterator: Iterator[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableOnce
    Annotations
    @deprecatedOverriding( ... , "2.11.0" )
  221. def toJavaCollection[A, B](i: Iterator[A], f: (A) ⇒ B): Collection[B]

    Permalink

    Helper transformer from Scala iterator to Java collection.

    Helper transformer from Scala iterator to Java collection.

    i

    Scala iterator to transform.

    f

    Transforming function.

    Definition Classes
    ScalarConversions
  222. def toJavaCollection[A](s: Seq[A]): Collection[A]

    Permalink

    Helper converter from Scala sequence to Java collection.

    Helper converter from Scala sequence to Java collection.

    s

    Scala sequence to convert.

    Definition Classes
    ScalarConversions
  223. def toJavaCollection[A, B](s: Seq[A], f: (A) ⇒ B): Collection[B]

    Permalink

    Helper transformer from Scala sequence to Java collection.

    Helper transformer from Scala sequence to Java collection.

    s

    Scala sequence to transform.

    f

    Transforming function.

    Definition Classes
    ScalarConversions
  224. implicit def toJob(f: () ⇒ Any): ComputeJob

    Permalink

    Implicit converter from Scala function to ComputeJob.

    Implicit converter from Scala function to ComputeJob.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  225. def toList: List[ClusterNode]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  226. def toMap[T, U](implicit ev: <:<[ClusterNode, (T, U)]): Map[T, U]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  227. def toOutClosureX[R](f: () ⇒ R): IgniteOutClosureX[R]

    Permalink

    Implicit converter from Scala function to GridOutClosureX.

    Implicit converter from Scala function to GridOutClosureX.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  228. implicit def toPredicate[T](f: (T) ⇒ Boolean): IgnitePredicate[T]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  229. implicit def toPredicate2[T1, T2](f: (T1, T2) ⇒ Boolean): IgniteBiPredicate[T1, T2]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  230. def toPredicate2X[T1, T2](f: (T1, T2) ⇒ Boolean): IgnitePredicate2X[T1, T2]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  231. implicit def toPredicate3[T1, T2, T3](f: (T1, T2, T3) ⇒ Boolean): GridPredicate3[T1, T2, T3]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  232. def toPredicate32[T1, T2, T3](f: (T1, T2, T3) ⇒ Boolean): GridPredicate3X[T1, T2, T3]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  233. def toPredicateX[T](f: (T) ⇒ Boolean): IgnitePredicateX[T]

    Permalink

    Implicit converter from Scala predicate to Scala wrapping predicate.

    Implicit converter from Scala predicate to Scala wrapping predicate.

    f

    Scala predicate to convert.

    Definition Classes
    ScalarConversions
  234. implicit def toReducer[E, R](r: (Seq[E]) ⇒ R): IgniteReducer[E, R]

    Permalink

    Implicit converter from Scala function and Java GridReducer.

    Implicit converter from Scala function and Java GridReducer.

    r

    Scala function to convert.

    Definition Classes
    ScalarConversions
  235. implicit def toReducer2[E1, E2, R](r: (Seq[E1], Seq[E2]) ⇒ R): IgniteReducer2[E1, E2, R]

    Permalink

    Implicit converter from Scala function and Java GridReducer2.

    Implicit converter from Scala function and Java GridReducer2.

    r

    Scala function to convert.

    Definition Classes
    ScalarConversions
  236. implicit def toReducer3[E1, E2, E3, R](r: (Seq[E1], Seq[E2], Seq[E3]) ⇒ R): IgniteReducer3[E1, E2, E3, R]

    Permalink

    Implicit converter from Scala function and Java GridReducer3.

    Implicit converter from Scala function and Java GridReducer3.

    r

    Scala function to convert.

    Definition Classes
    ScalarConversions
  237. implicit def toReturnable(v: Any): AnyRef { def ^^: Unit }

    Permalink

    Introduction of ^^ operator for Any type that will call break.

    Introduction of ^^ operator for Any type that will call break.

    v

    Any value.

    Definition Classes
    ScalarConversions
  238. implicit def toRunnable(f: () ⇒ Unit): IgniteRunnable

    Permalink

    Implicit converter from Scala function to GridAbsClosure.

    Implicit converter from Scala function to GridAbsClosure.

    f

    Scala function to convert.

    Definition Classes
    ScalarConversions
  239. def toScalaItr[K, V](c: Collection[Entry[K, V]]): Iterable[(K, V)]

    Permalink

    Helper converter from Java entry collection to Scala iterable of pair.

    Helper converter from Java entry collection to Scala iterable of pair.

    c

    Java collection to convert.

    Definition Classes
    ScalarConversions
  240. def toScalaSeq[A](i: Iterable[A]): Seq[A]

    Permalink

    Helper converter from Java iterable to Scala sequence.

    Helper converter from Java iterable to Scala sequence.

    i

    Java iterable to convert.

    Definition Classes
    ScalarConversions
  241. def toScalaSeq[A, B](i: Iterable[A], f: (A) ⇒ B): Seq[B]

    Permalink

    Helper transformer from Java iterable to Scala sequence.

    Helper transformer from Java iterable to Scala sequence.

    i

    Java iterable to transform.

    f

    Transforming function.

    Definition Classes
    ScalarConversions
  242. def toScalaSeq[A](i: Iterator[A]): Seq[A]

    Permalink

    Helper converter from Java iterator to Scala sequence.

    Helper converter from Java iterator to Scala sequence.

    i

    Java iterator to convert.

    Definition Classes
    ScalarConversions
  243. def toScalaSeq[A, B](i: Iterator[A], f: (A) ⇒ B): Seq[B]

    Permalink

    Helper transformer from Java iterator to Scala sequence.

    Helper transformer from Java iterator to Scala sequence.

    i

    Java iterator to transform.

    f

    Transforming function.

    Definition Classes
    ScalarConversions
  244. def toScalaSeq[A, B](c: Collection[A], f: (A) ⇒ B): Seq[B]

    Permalink

    Helper transformer from Java collection to Scala sequence.

    Helper transformer from Java collection to Scala sequence.

    c

    Java collection to transform.

    f

    Transforming function.

    Definition Classes
    ScalarConversions
  245. implicit def toScalarCache[K, V](impl: IgniteCache[K, V]): ScalarCachePimp[K, V]

    Permalink

    Implicit converter from Cache to ScalarCachePimp "pimp".

    Implicit converter from Cache to ScalarCachePimp "pimp".

    impl

    Grid cache to convert.

    Definition Classes
    ScalarConversions
  246. implicit def toScalarGrid(impl: Ignite): ScalarGridPimp

    Permalink

    Implicit converter from Grid to ScalarGridPimp "pimp".

    Implicit converter from Grid to ScalarGridPimp "pimp".

    impl

    Grid to convert.

    Definition Classes
    ScalarConversions
  247. implicit def toScalarProjection(impl: ClusterGroup): ScalarProjectionPimp[ClusterGroup]

    Permalink

    Implicit converter from GridProjection to ScalarProjectionPimp "pimp".

    Implicit converter from GridProjection to ScalarProjectionPimp "pimp".

    impl

    Grid projection to convert.

    Definition Classes
    ScalarConversions
  248. def toSeq: Seq[ClusterNode]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  249. def toSet[B >: ClusterNode]: Set[B]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  250. def toStream: Stream[ClusterNode]

    Permalink
    Definition Classes
    IterableLike → TraversableLike → GenTraversableOnce
  251. def toString(): String

    Permalink
    Definition Classes
    TraversableLike → Any
  252. def toTraversable: Traversable[ClusterNode]

    Permalink
    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce
    Annotations
    @deprecatedOverriding( ... , "2.11.0" )
  253. implicit def toTuple2[A, B](t: (A, B)): IgniteBiTuple[A, B]

    Permalink

    Implicit converter from Scala tuple to GridTuple2.

    Implicit converter from Scala tuple to GridTuple2.

    t

    Scala tuple to convert.

    Definition Classes
    ScalarConversions
  254. implicit def toTuple2x[T1, T2](t: (T1, T2)): AnyRef { ... /* 5 definitions in type refinement */ }

    Permalink

    Extension for Tuple2.

    Extension for Tuple2.

    t

    Tuple to improve.

    Definition Classes
    ScalarConversions
  255. implicit def toTuple3[A, B, C](t: (A, B, C)): GridTuple3[A, B, C]

    Permalink

    Implicit converter from Scala tuple to GridTuple3.

    Implicit converter from Scala tuple to GridTuple3.

    t

    Scala tuple to convert.

    Definition Classes
    ScalarConversions
  256. implicit def toTuple3x[T1, T2, T3](t: (T1, T2, T3)): AnyRef { ... /* 6 definitions in type refinement */ }

    Permalink

    Extension for Tuple3.

    Extension for Tuple3.

    t

    Tuple to improve.

    Definition Classes
    ScalarConversions
  257. implicit def toTuple4[A, B, C, D](t: (A, B, C, D)): GridTuple4[A, B, C, D]

    Permalink

    Implicit converter from Scala tuple to GridTuple4.

    Implicit converter from Scala tuple to GridTuple4.

    t

    Scala tuple to convert.

    Definition Classes
    ScalarConversions
  258. implicit def toTuple5[A, B, C, D, E](t: (A, B, C, D, E)): GridTuple5[A, B, C, D, E]

    Permalink

    Implicit converter from Scala tuple to GridTuple5.

    Implicit converter from Scala tuple to GridTuple5.

    t

    Scala tuple to convert.

    Definition Classes
    ScalarConversions
  259. implicit def toVarArgs[T](s: Seq[(T) ⇒ Boolean]): Seq[IgnitePredicate[_ >: T]]

    Permalink

    Implicit converter from vararg of one-argument Scala functions to Java GridPredicates.

    Implicit converter from vararg of one-argument Scala functions to Java GridPredicates.

    s

    Sequence of one-argument Scala functions to convert.

    Definition Classes
    ScalarConversions
  260. implicit def toVarArgs2[T1, T2](s: Seq[(T1, T2) ⇒ Boolean]): Seq[IgniteBiPredicate[_ >: T1, _ >: T2]]

    Permalink

    Implicit converter from vararg of two-argument Scala functions to Java GridPredicate2s.

    Implicit converter from vararg of two-argument Scala functions to Java GridPredicate2s.

    s

    Sequence of two-argument Scala functions to convert.

    Definition Classes
    ScalarConversions
  261. implicit def toVarArgs3[T1, T2, T3](s: Seq[(T1, T2, T3) ⇒ Boolean]): Seq[GridPredicate3[_ >: T1, _ >: T2, _ >: T3]]

    Permalink

    Implicit converter from vararg of three-argument Scala functions to Java GridPredicate3s.

    Implicit converter from vararg of three-argument Scala functions to Java GridPredicate3s.

    s

    Sequence of three-argument Scala functions to convert.

    Definition Classes
    ScalarConversions
  262. def toVector: Vector[ClusterNode]

    Permalink
    Definition Classes
    TraversableOnce → GenTraversableOnce
  263. def transpose[B](implicit asTraversable: (ClusterNode) ⇒ GenTraversableOnce[B]): Iterable[Iterable[B]]

    Permalink
    Definition Classes
    GenericTraversableTemplate
    Annotations
    @migration
    Migration

    (Changed in version 2.9.0) transpose throws an IllegalArgumentException if collections are not uniformly sized.

  264. implicit def tuple2DotScala[A, B](t: IgniteBiTuple[A, B]): AnyRef { def scala: (A, B) }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

    Definition Classes
    ScalarConversions
  265. implicit def tuple3DotScala[A, B, C](t: GridTuple3[A, B, C]): AnyRef { def scala: (A, B, C) }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

    Definition Classes
    ScalarConversions
  266. implicit def tuple4DotScala[A, B, C, D](t: GridTuple4[A, B, C, D]): AnyRef { def scala: (A, B, C, D) }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

    Definition Classes
    ScalarConversions
  267. implicit def tuple5DotScala[A, B, C, D, E](t: GridTuple5[A, B, C, D, E]): AnyRef { def scala: (A, B, C, D, E) }

    Permalink

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

    Definition Classes
    ScalarConversions
  268. def unzip[A1, A2](implicit asPair: (ClusterNode) ⇒ (A1, A2)): (Iterable[A1], Iterable[A2])

    Permalink
    Definition Classes
    GenericTraversableTemplate
  269. def unzip3[A1, A2, A3](implicit asTriple: (ClusterNode) ⇒ (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])

    Permalink
    Definition Classes
    GenericTraversableTemplate
  270. lazy val value: A

    Permalink

    Definition Classes
    ScalarProjectionPimpPimpedType
  271. def view(from: Int, until: Int): IterableView[ClusterNode, Iterable[ClusterNode]]

    Permalink
    Definition Classes
    IterableLike → TraversableLike
  272. def view: IterableView[ClusterNode, Iterable[ClusterNode]]

    Permalink
    Definition Classes
    IterableLike → TraversableLike
  273. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  274. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  275. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  276. def withFilter(p: (ClusterNode) ⇒ Boolean): FilterMonadic[ClusterNode, Iterable[ClusterNode]]

    Permalink
    Definition Classes
    TraversableLike → FilterMonadic
  277. def withName$(taskName: String): A

    Permalink

    Properly typed version of Compute#withName(...) method.

    Properly typed version of Compute#withName(...) method.

    taskName

    Name of the task.

    Definition Classes
    ScalarTaskThreadContext
  278. def withNoFailover$(): A

    Permalink

    Properly typed version of Compute#withNoFailover() method.

    Properly typed version of Compute#withNoFailover() method.

    Definition Classes
    ScalarTaskThreadContext
  279. def zip[A1 >: ClusterNode, B, That](that: GenIterable[B])(implicit bf: CanBuildFrom[Iterable[ClusterNode], (A1, B), That]): That

    Permalink
    Definition Classes
    IterableLike → GenIterableLike
  280. def zipAll[B, A1 >: ClusterNode, That](that: GenIterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[ClusterNode], (A1, B), That]): That

    Permalink
    Definition Classes
    IterableLike → GenIterableLike
  281. def zipWithIndex[A1 >: ClusterNode, That](implicit bf: CanBuildFrom[Iterable[ClusterNode], (A1, Int), That]): That

    Permalink
    Definition Classes
    IterableLike → GenIterableLike

Inherited from ScalarTaskThreadContext[A]

Inherited from ScalarConversions

Inherited from Iterable[ClusterNode]

Inherited from IterableLike[ClusterNode, Iterable[ClusterNode]]

Inherited from Equals

Inherited from GenIterable[ClusterNode]

Inherited from GenIterableLike[ClusterNode, Iterable[ClusterNode]]

Inherited from Traversable[ClusterNode]

Inherited from GenTraversable[ClusterNode]

Inherited from GenericTraversableTemplate[ClusterNode, Iterable]

Inherited from TraversableLike[ClusterNode, Iterable[ClusterNode]]

Inherited from GenTraversableLike[ClusterNode, Iterable[ClusterNode]]

Inherited from Parallelizable[ClusterNode, ParIterable[ClusterNode]]

Inherited from TraversableOnce[ClusterNode]

Inherited from GenTraversableOnce[ClusterNode]

Inherited from FilterMonadic[ClusterNode, Iterable[ClusterNode]]

Inherited from HasNewBuilder[ClusterNode, Iterable[org.apache.ignite.cluster.ClusterNode] @scala.annotation.unchecked.uncheckedVariance]

Inherited from PimpedType[A]

Inherited from AnyRef

Inherited from Any

Ungrouped