water.api.RDDs

RDDsHandler

class RDDsHandler extends Handler

RDDs handler.

Linear Supertypes
Handler, H2OCountedCompleter[T], Freezable[T], Cloneable, CountedCompleter, ForkJoinTask[Void], Serializable, Future[Void], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RDDsHandler
  2. Handler
  3. H2OCountedCompleter
  4. Freezable
  5. Cloneable
  6. CountedCompleter
  7. ForkJoinTask
  8. Serializable
  9. Future
  10. AnyRef
  11. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RDDsHandler(sc: SparkContext)

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def __tryComplete(arg0: CountedCompleter): Unit

    Definition Classes
    CountedCompleter

  7. final def addToPendingCount(arg0: Int): Unit

    Definition Classes
    CountedCompleter

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. def cancel(arg0: Boolean): Boolean

    Definition Classes
    ForkJoinTask → Future

  10. final def clone(): T

    Definition Classes
    H2OCountedCompleter → Freezable → AnyRef

  11. final def compareAndSetForkJoinTaskTag(arg0: Short, arg1: Short): Boolean

    Definition Classes
    ForkJoinTask

  12. final def compareAndSetPendingCount(arg0: Int, arg1: Int): Boolean

    Definition Classes
    CountedCompleter

  13. def complete(arg0: Void): Unit

    Definition Classes
    CountedCompleter → ForkJoinTask

  14. def completeExceptionally(arg0: Throwable): Unit

    Definition Classes
    ForkJoinTask

  15. final def compute(): Unit

    Definition Classes
    H2OCountedCompleter → CountedCompleter

  16. final def compute2(): Unit

    Attributes
    protected[water.api]
    Definition Classes
    Handler → H2OCountedCompleter

  17. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  18. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  19. final def exec(): Boolean

    Attributes
    protected[jsr166y]
    Definition Classes
    CountedCompleter → ForkJoinTask

  20. def fetchAll(): Array[IcedRDDInfo]

  21. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  22. final def fork(): ForkJoinTask[Void]

    Definition Classes
    ForkJoinTask

  23. final def frozenType(): Int

    Definition Classes
    H2OCountedCompleter → Freezable

  24. final def get(arg0: Long, arg1: TimeUnit): Void

    Definition Classes
    ForkJoinTask → Future
    Annotations
    @throws( ... ) @throws( ... ) @throws( ... )

  25. final def get(): Void

    Definition Classes
    ForkJoinTask → Future
    Annotations
    @throws( ... ) @throws( ... )

  26. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  27. final def getCompleter(): CountedCompleter

    Definition Classes
    CountedCompleter

  28. final def getException(): Throwable

    Definition Classes
    ForkJoinTask

  29. final def getForkJoinTaskTag(): Short

    Definition Classes
    ForkJoinTask

  30. final def getPendingCount(): Int

    Definition Classes
    CountedCompleter

  31. def getRDD(version: Int, s: RDDWithMsgV3): RDDWithMsgV3

  32. final def getRawResult(): Void

    Definition Classes
    CountedCompleter → ForkJoinTask

  33. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  34. def icer(): Icer[T]

    Attributes
    protected[water]
    Definition Classes
    H2OCountedCompleter

  35. final def invoke(): Void

    Definition Classes
    ForkJoinTask

  36. final def isCancelled(): Boolean

    Definition Classes
    ForkJoinTask → Future

  37. final def isCompletedAbnormally(): Boolean

    Definition Classes
    ForkJoinTask

  38. final def isCompletedNormally(): Boolean

    Definition Classes
    ForkJoinTask

  39. final def isDone(): Boolean

    Definition Classes
    ForkJoinTask → Future

  40. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  41. final def join(): Void

    Definition Classes
    ForkJoinTask

  42. def list(version: Int, s: RDDsV3): RDDsV3

  43. def markdown(arg0: Handler, arg1: Int, arg2: StringBuffer, arg3: String): StringBuffer

    Attributes
    protected[water.api]
    Definition Classes
    Handler

  44. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  45. final def nextThrPriority(): Byte

    Attributes
    protected[water]
    Definition Classes
    H2OCountedCompleter

  46. final def notify(): Unit

    Definition Classes
    AnyRef

  47. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  48. def onCompletion(arg0: CountedCompleter): Unit

    Definition Classes
    CountedCompleter

  49. def onExceptionalCompletion(arg0: Throwable, arg1: CountedCompleter): Boolean

    Definition Classes
    H2OCountedCompleter → CountedCompleter

  50. def priority(): Byte

    Attributes
    protected[water]
    Definition Classes
    H2OCountedCompleter

  51. final def quietlyComplete(): Unit

    Definition Classes
    ForkJoinTask

  52. final def quietlyInvoke(): Unit

    Definition Classes
    ForkJoinTask

  53. final def quietlyJoin(): Unit

    Definition Classes
    ForkJoinTask

  54. final def read(arg0: AutoBuffer): T

    Definition Classes
    H2OCountedCompleter → Freezable

  55. final def readJSON(arg0: AutoBuffer): T

    Definition Classes
    H2OCountedCompleter → Freezable

  56. def readJSON_impl(arg0: AutoBuffer): T

    Definition Classes
    H2OCountedCompleter → Freezable

  57. def read_impl(arg0: AutoBuffer): T

    Definition Classes
    H2OCountedCompleter → Freezable

  58. def reinitialize(): Unit

    Definition Classes
    ForkJoinTask

  59. val sc: SparkContext

  60. final def setCompleter(arg0: CountedCompleter): Unit

    Definition Classes
    CountedCompleter

  61. final def setForkJoinTaskTag(arg0: Short): Short

    Definition Classes
    ForkJoinTask

  62. final def setPendingCount(arg0: Int): Unit

    Definition Classes
    CountedCompleter

  63. final def setRawResult(arg0: Void): Unit

    Attributes
    protected[jsr166y]
    Definition Classes
    CountedCompleter → ForkJoinTask

  64. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  65. def toString(): String

    Definition Classes
    AnyRef → Any

  66. final def tryComplete(): Unit

    Definition Classes
    CountedCompleter

  67. def tryUnfork(): Boolean

    Definition Classes
    ForkJoinTask

  68. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  69. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  70. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  71. final def write(arg0: AutoBuffer): AutoBuffer

    Definition Classes
    H2OCountedCompleter → Freezable

  72. final def writeJSON(arg0: AutoBuffer): AutoBuffer

    Definition Classes
    H2OCountedCompleter → Freezable

  73. def writeJSON_impl(arg0: AutoBuffer): AutoBuffer

    Definition Classes
    H2OCountedCompleter → Freezable

  74. def write_impl(arg0: AutoBuffer): AutoBuffer

    Definition Classes
    H2OCountedCompleter → Freezable

Inherited from Handler

Inherited from H2OCountedCompleter[T]

Inherited from Freezable[T]

Inherited from Cloneable

Inherited from CountedCompleter

Inherited from ForkJoinTask[Void]

Inherited from Serializable

Inherited from Future[Void]

Inherited from AnyRef

Inherited from Any

Ungrouped