org.apache.ignite.scalar.pimps

ScalarProjectionPimp

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
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ScalarProjectionPimp()

Type Members

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

    Type alias for '() => R'.

    Type alias for '() => R'.

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

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

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

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

    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

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

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

    Attributes
    protected
  5. type NF = IgnitePredicate[ClusterNode]

    Type alias for node filter predicate.

    Type alias for node filter predicate.

    Attributes
    protected
  6. type Pred = () ? Boolean

    Type alias for '() => Boolean'.

    Type alias for '() => Boolean'.

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

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

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

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

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

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

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

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

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

    Attributes
    protected
  10. type Run = () ? Unit

    Type alias for '() => Unit'.

    Type alias for '() => Unit'.

    Attributes
    protected
  11. type Self = Iterable[ClusterNode]

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

    Definition Classes
    TraversableLike

Value Members

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

    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

    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

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

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

    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]

    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]]

    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]]

    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

    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

    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[_]

    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[_]

    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

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

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

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

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

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

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

    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]

    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 }

    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 }

    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 }

    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 }

    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

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

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

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

    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 GridComputeTask 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[_]

    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 GridComputeTask 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

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

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

    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]

    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]

    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]]

    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]]

    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]

    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]

    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

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

    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 }

    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 }

    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 }

    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 }

    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 }

    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 }

    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

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

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    AnyRef ? Any
  60. def exists(p: (ClusterNode) ? Boolean): Boolean

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

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

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

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

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

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

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

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

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

    Definition Classes
    IterableLike ? TraversableOnce ? GenTraversableOnce
  70. def forall(p: (ClusterNode) ? Boolean): Boolean

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

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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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)

    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)

    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)

    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)

    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]]

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

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

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

    Definition Classes
    IterableLike
  108. def hasDefiniteSize: Boolean

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

    Definition Classes
    AnyRef ? Any
  110. def head: ClusterNode

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

    Definition Classes
    TraversableLike ? GenTraversableLike
  112. var impl: A

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

    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 }

    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 }

    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 }

    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 }

    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 }

    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]

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

    Definition Classes
    TraversableLike
  121. def isEmpty: Boolean

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

    Definition Classes
    Any
  123. final def isTraversableAgain: Boolean

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

    Gets iterator for this projection's nodes.

    Gets iterator for this projection's nodes.

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

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

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

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

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

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

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

    Definition Classes
    TraversableOnce ? GenTraversableOnce
  132. def mkString: String

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

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

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

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

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

    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

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

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

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

    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 }

    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]

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

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

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

    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 }

    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 }

    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 }

    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 }

    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 }

    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

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

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

    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]

    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

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

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

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

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

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

    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 }

    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 }

    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 }

    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]

    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]

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

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

    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

    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[_]

    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[_]

    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

    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

    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

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

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

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

    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

    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

    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]

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

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

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

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

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

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

    Definition Classes
    TraversableLike ? GenTraversableLike
  187. def stringPrefix: String

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

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

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

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

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

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

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

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

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

    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]

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

    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

    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

    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

    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]

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

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

    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]

    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]

    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]

    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]

    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]

    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]

    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]

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

    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]

    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]

    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]

    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]

    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]

    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]

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

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

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

    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]

    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]

    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

    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]

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

    Definition Classes
    TraversableOnce ? GenTraversableOnce
  227. implicit def toOutClosure2[R](c: Callable[R]): IgniteOutClosure[R]

    Implicit converter from java.util.concurrent.Callable to GridOutClosure.

    Implicit converter from java.util.concurrent.Callable to GridOutClosure.

    c

    Java callable to convert.

    Definition Classes
    ScalarConversions
  228. def toOutClosureX[R](f: () ? R): IgniteOutClosureX[R]

    Implicit converter from Scala function to GridOutClosureX.

    Implicit converter from Scala function to GridOutClosureX.

    f

    Scala function to convert.

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

    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. implicit def toPredicate2[T1, T2](f: (T1, T2) ? Boolean): IgniteBiPredicate[T1, T2]

    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. def toPredicate2X[T1, T2](f: (T1, T2) ? Boolean): IgnitePredicate2X[T1, T2]

    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. implicit def toPredicate3[T1, T2, T3](f: (T1, T2, T3) ? Boolean): GridPredicate3[T1, T2, T3]

    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 toPredicate32[T1, T2, T3](f: (T1, T2, T3) ? Boolean): GridPredicate3X[T1, T2, T3]

    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. def toPredicateX[T](f: (T) ? Boolean): IgnitePredicateX[T]

    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
  235. implicit def toReducer[E, R](r: (Seq[E]) ? R): IgniteReducer[E, R]

    Implicit converter from Scala function and Java GridReducer.

    Implicit converter from Scala function and Java GridReducer.

    r

    Scala function to convert.

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

    Implicit converter from Scala function and Java GridReducer2.

    Implicit converter from Scala function and Java GridReducer2.

    r

    Scala function to convert.

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

    Implicit converter from Scala function and Java GridReducer3.

    Implicit converter from Scala function and Java GridReducer3.

    r

    Scala function to convert.

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

    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
  239. implicit def toRunnable(f: () ? Unit): IgniteRunnable

    Implicit converter from Scala function to GridAbsClosure.

    Implicit converter from Scala function to GridAbsClosure.

    f

    Scala function to convert.

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

    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
  241. def toScalaSeq[A](i: Iterable[A]): Seq[A]

    Helper converter from Java iterable to Scala sequence.

    Helper converter from Java iterable to Scala sequence.

    i

    Java iterable to convert.

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

    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
  243. def toScalaSeq[A](i: Iterator[A]): Seq[A]

    Helper converter from Java iterator to Scala sequence.

    Helper converter from Java iterator to Scala sequence.

    i

    Java iterator to convert.

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

    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
  245. def toScalaSeq[A, B](c: Collection[A], f: (A) ? B): Seq[B]

    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
  246. implicit def toScalarCache[K, V](impl: IgniteCache[K, V]): ScalarCachePimp[K, V]

    Implicit converter from Cache to ScalarCachePimp "pimp".

    Implicit converter from Cache to ScalarCachePimp "pimp".

    impl

    Grid cache to convert.

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

    Implicit converter from Grid to ScalarGridPimp "pimp".

    Implicit converter from Grid to ScalarGridPimp "pimp".

    impl

    Grid to convert.

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

    Implicit converter from GridProjection to ScalarProjectionPimp "pimp".

    Implicit converter from GridProjection to ScalarProjectionPimp "pimp".

    impl

    Grid projection to convert.

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

    Definition Classes
    TraversableOnce ? GenTraversableOnce
  250. def toSet[B >: ClusterNode]: Set[B]

    Definition Classes
    TraversableOnce ? GenTraversableOnce
  251. def toStream: Stream[ClusterNode]

    Definition Classes
    IterableLike ? TraversableLike ? GenTraversableOnce
  252. def toString(): String

    Definition Classes
    TraversableLike ? Any
  253. def toTraversable: Traversable[ClusterNode]

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

    Implicit converter from Scala tuple to GridTuple2.

    Implicit converter from Scala tuple to GridTuple2.

    t

    Scala tuple to convert.

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

    Extension for Tuple2.

    Extension for Tuple2.

    t

    Tuple to improve.

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

    Implicit converter from Scala tuple to GridTuple3.

    Implicit converter from Scala tuple to GridTuple3.

    t

    Scala tuple to convert.

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

    Extension for Tuple3.

    Extension for Tuple3.

    t

    Tuple to improve.

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

    Implicit converter from Scala tuple to GridTuple4.

    Implicit converter from Scala tuple to GridTuple4.

    t

    Scala tuple to convert.

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

    Implicit converter from Scala tuple to GridTuple5.

    Implicit converter from Scala tuple to GridTuple5.

    t

    Scala tuple to convert.

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

    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
  261. implicit def toVarArgs2[T1, T2](s: Seq[(T1, T2) ? Boolean]): Seq[IgniteBiPredicate[_ >: T1, _ >: T2]]

    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
  262. implicit def toVarArgs3[T1, T2, T3](s: Seq[(T1, T2, T3) ? Boolean]): Seq[GridPredicate3[_ >: T1, _ >: T2, _ >: T3]]

    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
  263. def toVector: Vector[ClusterNode]

    Definition Classes
    TraversableOnce ? GenTraversableOnce
  264. def transpose[B](implicit asTraversable: (ClusterNode) ? GenTraversableOnce[B]): Iterable[Iterable[B]]

    Definition Classes
    GenericTraversableTemplate
    Annotations
    @migration
    Migration

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

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

    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 tuple3DotScala[A, B, C](t: GridTuple3[A, B, C]): AnyRef { def scala: (A, B, C) }

    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 tuple4DotScala[A, B, C, D](t: GridTuple4[A, B, C, D]): AnyRef { def scala: (A, B, C, D) }

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

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

    Pimp for adding explicit conversion method scala.

    Pimp for adding explicit conversion method scala.

    t

    Java-side tuple to pimp.

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

    Definition Classes
    GenericTraversableTemplate
  270. def unzip3[A1, A2, A3](implicit asTriple: (ClusterNode) ? (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])

    Definition Classes
    GenericTraversableTemplate
  271. lazy val value: A

    Definition Classes
    ScalarProjectionPimp ? PimpedType
  272. def view(from: Int, until: Int): IterableView[ClusterNode, Iterable[ClusterNode]]

    Definition Classes
    IterableLike ? TraversableLike
  273. def view: IterableView[ClusterNode, Iterable[ClusterNode]]

    Definition Classes
    IterableLike ? TraversableLike
  274. final def wait(): Unit

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

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

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

    Definition Classes
    TraversableLike ? FilterMonadic
  278. def withName$(taskName: String): A

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

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

    taskName

    Name of the task.

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

    Properly typed version of GridCompute#withNoFailover() method.

    Properly typed version of GridCompute#withNoFailover() method.

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

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

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

    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

Ignite™ - Scalar DSL, ver. 1.0.0-RC3
2015 Copyright © Apache Software Foundation