ScalaCodeHandler

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. def asBytes(): Array[Byte]

   Definition Classes

   H2OCountedCompleter → Freezable

9. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

10. def buildSparkMajorVersion: String

    Returns Major Spark version for which is this version of Sparkling Water designated.

    Returns Major Spark version for which is this version of Sparkling Water designated.

    For example, for 1.6.1 returns 1.6

    Definition Classes

    H2OConf

11. def cancel(arg0: Boolean): Boolean

    Definition Classes

    ForkJoinTask → Future

12. def clientBasePort: Int

    Definition Classes

    H2OConf

13. def clientIcedDir: Option[String]

    Definition Classes

    H2OConf

14. def clientIp: Option[String]

    Definition Classes

    H2OConf

15. def clientWebPort: Int

    Definition Classes

    H2OConf

16. final def clone(): T

    Definition Classes

    H2OCountedCompleter → Freezable → AnyRef

17. def cloudName: String

    Definition Classes

    H2OConf

18. def cloudTimeout: Int

    Definition Classes

    H2OConf

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

    Definition Classes

    ForkJoinTask

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

    Definition Classes

    CountedCompleter

21. def complete(arg0: Void): Unit

    Definition Classes

    CountedCompleter → ForkJoinTask

22. def completeExceptionally(arg0: Throwable): Unit

    Definition Classes

    ForkJoinTask

23. final def compute(): Unit

    Definition Classes

    H2OCountedCompleter → CountedCompleter

24. def compute1(): Unit

    Definition Classes

    H2OCountedCompleter

25. final def compute2(): Unit

    Definition Classes

    Handler → H2OCountedCompleter

26. def createID(): Int

27. def createInterpreterInPool(): H2OInterpreter

28. def defaultCloudSize: Int

    Definition Classes

    H2OConf

29. def destroySession(version: Int, s: ScalaSessionIdV3): ScalaSessionIdV3

30. def disableGA: Boolean

    Definition Classes

    H2OConf

31. def drddMulFactor: Int

    Definition Classes

    H2OConf

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

    Definition Classes

    AnyRef

33. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

34. final def exec(): Boolean

    Attributes

    protected[jsr166y]

    Definition Classes

    CountedCompleter → ForkJoinTask

35. def fetchInterpreter(): H2OInterpreter

36. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

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

    Definition Classes

    ForkJoinTask

38. val freeInterpreters: ConcurrentLinkedQueue[H2OInterpreter]

39. final def frozenType(): Int

    Definition Classes

    H2OCountedCompleter → Freezable

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

    Definition Classes

    ForkJoinTask → Future

    Annotations

    @throws( ... ) @throws( ... ) @throws( ... )

41. final def get(): Void

    Definition Classes

    ForkJoinTask → Future

    Annotations

    @throws( ... ) @throws( ... )

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

    Definition Classes

    AnyRef → Any

43. final def getCompleter(): CountedCompleter

    Definition Classes

    CountedCompleter

44. final def getException(): Throwable

    Definition Classes

    ForkJoinTask

45. final def getForkJoinTaskTag(): Short

    Definition Classes

    ForkJoinTask

46. def getH2OClientArgs: Array[String]

    Get arguments for H2O client.

    Get arguments for H2O client.

    returns

    array of H2O client arguments.

    Definition Classes

    H2OConf

47. def getH2ONodeArgs: Array[String]

    Produce arguments for H2O node based on this config.

    Produce arguments for H2O node based on this config.

    returns

    array of H2O launcher command line arguments

    Definition Classes

    H2OConf

48. final def getPendingCount(): Int

    Definition Classes

    CountedCompleter

49. final def getRawResult(): Void

    Definition Classes

    CountedCompleter → ForkJoinTask

50. def getSessions(version: Int, s: ScalaSessionsV3): ScalaSessionsV3

51. def h2oClientLogDir: String

    Definition Classes

    H2OConf

52. def h2oClientLogLevel: String

    Definition Classes

    H2OConf

53. def h2oNodeLogDir: String

    Definition Classes

    H2OConf

54. def h2oNodeLogLevel: String

    Definition Classes

    H2OConf

55. def hashCode(): Int

    Definition Classes

    AnyRef → Any

56. def hashLogin: Boolean

    Definition Classes

    H2OConf

57. def icer(): Icer[T]

    Attributes

    protected[water]

    Definition Classes

    H2OCountedCompleter

58. def initSession(version: Int, s: ScalaSessionIdV3): ScalaSessionIdV3

59. def initializeInterpeterPool(): Unit

60. def interpret(version: Int, s: ScalaCodeV3): ScalaCodeV3

61. val intrPoolSize: Int

62. final def invoke(): Void

    Definition Classes

    ForkJoinTask

63. final def isCancelled(): Boolean

    Definition Classes

    ForkJoinTask → Future

64. def isClusterTopologyListenerEnabled: Boolean

    Definition Classes

    H2OConf

65. final def isCompletedAbnormally(): Boolean

    Definition Classes

    ForkJoinTask

66. final def isCompletedNormally(): Boolean

    Definition Classes

    ForkJoinTask

67. final def isDone(): Boolean

    Definition Classes

    ForkJoinTask → Future

68. def isH2OReplEnabled: Boolean

    Definition Classes

    H2OConf

69. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

70. def isSparkVersionCheckEnabled: Boolean

    Definition Classes

    H2OConf

71. def jks: Option[String]

    Definition Classes

    H2OConf

72. def jksPass: Option[String]

    Definition Classes

    H2OConf

73. final def join(): Void

    Definition Classes

    ForkJoinTask

74. var lastIdUsed: Int

75. def ldapLogin: Boolean

    Definition Classes

    H2OConf

76. def loginConf: Option[String]

    Definition Classes

    H2OConf

77. var mapIntr: TrieMap[Int, H2OInterpreter]

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

    Attributes

    protected[water.api]

    Definition Classes

    Handler

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

    Definition Classes

    AnyRef

80. def networkMask: Option[String]

    Definition Classes

    H2OConf

81. def nodeBasePort: Int

    Definition Classes

    H2OConf

82. def nodeIcedDir: Option[String]

    Definition Classes

    H2OConf

83. final def notify(): Unit

    Definition Classes

    AnyRef

84. final def notifyAll(): Unit

    Definition Classes

    AnyRef

85. def nthreads: Int

    Definition Classes

    H2OConf

86. def numH2OWorkers: Option[Int]

    Definition Classes

    H2OConf

87. def numRddRetries: Int

    Definition Classes

    H2OConf

88. def onCompletion(arg0: CountedCompleter): Unit

    Definition Classes

    CountedCompleter

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

    Definition Classes

    CountedCompleter

90. final def priority(): Byte

    Attributes

    protected[water]

    Definition Classes

    H2OCountedCompleter

91. final def quietlyComplete(): Unit

    Definition Classes

    ForkJoinTask

92. final def quietlyInvoke(): Unit

    Definition Classes

    ForkJoinTask

93. final def quietlyJoin(): Unit

    Definition Classes

    ForkJoinTask

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

    Definition Classes

    H2OCountedCompleter → Freezable

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

    Definition Classes

    H2OCountedCompleter → Freezable

96. def reinitialize(): Unit

    Definition Classes

    ForkJoinTask

97. def reloadFromBytes(arg0: Array[Byte]): T

    Definition Classes

    H2OCountedCompleter → Freezable

98. val sc: SparkContext

99. def scalaIntDefaultNum: Int

    Definition Classes

    H2OConf

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

     Definition Classes

     CountedCompleter

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

     Definition Classes

     ForkJoinTask

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

     Definition Classes

     CountedCompleter

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

     Attributes

     protected[jsr166y]

     Definition Classes

     CountedCompleter → ForkJoinTask

104. def sparkConf: SparkConf

     Definition Classes

     ScalaCodeHandler → H2OConf

105. def subseqTries: Int

     Definition Classes

     H2OConf

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

     Definition Classes

     AnyRef

107. def toString(): String

     Definition Classes

     H2OConf → AnyRef → Any

108. final def tryComplete(): Unit

     Definition Classes

     CountedCompleter

109. def tryUnfork(): Boolean

     Definition Classes

     ForkJoinTask

110. def useFlatFile: Boolean

     Definition Classes

     H2OConf

111. def userName: Option[String]

     Definition Classes

     H2OConf

112. final def wait(): Unit

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     H2OCountedCompleter → Freezable

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

     Definition Classes

     H2OCountedCompleter → Freezable