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 clientNetworkMask: Option[String]

    Definition Classes

    H2OConf

16. def clientVerboseOutput: Boolean

    Definition Classes

    H2OConf

17. def clientWebPort: Int

    Definition Classes

    H2OConf

18. final def clone(): Handler

    Definition Classes

    H2OCountedCompleter → Freezable → AnyRef

19. def cloudName: String

    Definition Classes

    H2OConf

20. def cloudTimeout: Int

    Definition Classes

    H2OConf

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

    Definition Classes

    ForkJoinTask

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

    Definition Classes

    CountedCompleter

23. def complete(arg0: Void): Unit

    Definition Classes

    CountedCompleter → ForkJoinTask

24. def completeExceptionally(arg0: Throwable): Unit

    Definition Classes

    ForkJoinTask

25. final def compute(): Unit

    Definition Classes

    H2OCountedCompleter → CountedCompleter

26. def compute1(): Unit

    Definition Classes

    H2OCountedCompleter

27. def compute2(): Unit

    Definition Classes

    H2OCountedCompleter

28. def createID(): Int

29. def createInterpreterInPool(): H2OInterpreter

30. def defaultCloudSize: Int

    Definition Classes

    H2OConf

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

32. def disableGA: Boolean

    Definition Classes

    H2OConf

33. def drddMulFactor: Int

    Definition Classes

    H2OConf

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

    Definition Classes

    AnyRef

35. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

36. final def exec(): Boolean

    Attributes

    protected[jsr166y]

    Definition Classes

    CountedCompleter → ForkJoinTask

37. def fetchInterpreter(): H2OInterpreter

38. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    ForkJoinTask

40. val freeInterpreters: ConcurrentLinkedQueue[H2OInterpreter]

41. final def frozenType(): Int

    Definition Classes

    H2OCountedCompleter → Freezable

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

    Definition Classes

    ForkJoinTask → Future

    Annotations

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

43. final def get(): Void

    Definition Classes

    ForkJoinTask → Future

    Annotations

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

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

    Definition Classes

    AnyRef → Any

45. final def getCompleter(): CountedCompleter

    Definition Classes

    CountedCompleter

46. final def getException(): Throwable

    Definition Classes

    ForkJoinTask

47. final def getForkJoinTaskTag(): Short

    Definition Classes

    ForkJoinTask

48. def getH2OClientArgs(ip: String): Array[String]

    Get arguments for H2O client.

    Get arguments for H2O client.

    returns

    array of H2O client arguments.

    Definition Classes

    H2OConf

49. 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

50. final def getPendingCount(): Int

    Definition Classes

    CountedCompleter

51. final def getRawResult(): Void

    Definition Classes

    CountedCompleter → ForkJoinTask

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

53. def h2oClientLogDir: String

    Definition Classes

    H2OConf

54. def h2oClientLogLevel: String

    Definition Classes

    H2OConf

55. def h2oNodeLogDir: String

    Definition Classes

    H2OConf

56. def h2oNodeLogLevel: String

    Definition Classes

    H2OConf

57. def hashCode(): Int

    Definition Classes

    AnyRef → Any

58. def hashLogin: Boolean

    Definition Classes

    H2OConf

59. def icer(): Icer[Handler]

    Attributes

    protected[water]

    Definition Classes

    H2OCountedCompleter

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

61. def initializeInterpeterPool(): Unit

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

63. val intrPoolSize: Int

64. final def invoke(): Void

    Definition Classes

    ForkJoinTask

65. final def isCancelled(): Boolean

    Definition Classes

    ForkJoinTask → Future

66. def isClusterTopologyListenerEnabled: Boolean

    Definition Classes

    H2OConf

67. final def isCompletedAbnormally(): Boolean

    Definition Classes

    ForkJoinTask

68. final def isCompletedNormally(): Boolean

    Definition Classes

    ForkJoinTask

69. final def isDone(): Boolean

    Definition Classes

    ForkJoinTask → Future

70. def isFailOnUnsupportedSparkParamEnabled: Boolean

    Definition Classes

    H2OConf

71. def isH2OReplEnabled: Boolean

    Definition Classes

    H2OConf

72. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

73. def isSparkVersionCheckEnabled: Boolean

    Definition Classes

    H2OConf

74. def jks: Option[String]

    Definition Classes

    H2OConf

75. def jksPass: Option[String]

    Definition Classes

    H2OConf

76. final def join(): Void

    Definition Classes

    ForkJoinTask

77. def kerberosLogin: Boolean

    Definition Classes

    H2OConf

78. var lastIdUsed: Int

79. def ldapLogin: Boolean

    Definition Classes

    H2OConf

80. def loginConf: Option[String]

    Definition Classes

    H2OConf

81. var mapIntr: TrieMap[Int, H2OInterpreter]

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

    Attributes

    protected[water.api]

    Definition Classes

    Handler

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

    Definition Classes

    AnyRef

84. def nodeBasePort: Int

    Definition Classes

    H2OConf

85. def nodeIcedDir: Option[String]

    Definition Classes

    H2OConf

86. def nodeNetworkMask: Option[String]

    Definition Classes

    H2OConf

87. final def notify(): Unit

    Definition Classes

    AnyRef

88. final def notifyAll(): Unit

    Definition Classes

    AnyRef

89. def nthreads: Int

    Definition Classes

    H2OConf

90. def numH2OWorkers: Option[Int]

    Definition Classes

    H2OConf

91. def numRddRetries: Int

    Definition Classes

    H2OConf

92. def onCompletion(arg0: CountedCompleter): Unit

    Definition Classes

    CountedCompleter

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

    Definition Classes

    CountedCompleter

94. final def priority(): Byte

    Attributes

    protected[water]

    Definition Classes

    H2OCountedCompleter

95. final def quietlyComplete(): Unit

    Definition Classes

    ForkJoinTask

96. final def quietlyInvoke(): Unit

    Definition Classes

    ForkJoinTask

97. final def quietlyJoin(): Unit

    Definition Classes

    ForkJoinTask

98. final def read(arg0: AutoBuffer): Handler

    Definition Classes

    H2OCountedCompleter → Freezable

99. final def readJSON(arg0: AutoBuffer): Handler

    Definition Classes

    H2OCountedCompleter → Freezable

100. def reinitialize(): Unit

     Definition Classes

     ForkJoinTask

101. def reloadFromBytes(arg0: Array[Byte]): Handler

     Definition Classes

     H2OCountedCompleter → Freezable

102. val sc: SparkContext

103. def scalaIntDefaultNum: Int

     Definition Classes

     H2OConf

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

     Definition Classes

     CountedCompleter

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

     Definition Classes

     ForkJoinTask

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

     Definition Classes

     CountedCompleter

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

     Attributes

     protected[jsr166y]

     Definition Classes

     CountedCompleter → ForkJoinTask

108. def sparkConf: SparkConf

     Definition Classes

     ScalaCodeHandler → H2OConf

109. def subseqTries: Int

     Definition Classes

     H2OConf

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

     Definition Classes

     AnyRef

111. def toString(): String

     Definition Classes

     H2OConf → AnyRef → Any

112. final def tryComplete(): Unit

     Definition Classes

     CountedCompleter

113. def tryUnfork(): Boolean

     Definition Classes

     ForkJoinTask

114. def useFlatFile: Boolean

     Definition Classes

     H2OConf

115. def userName: Option[String]

     Definition Classes

     H2OConf

116. final def wait(): Unit

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     H2OCountedCompleter → Freezable

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

     Definition Classes

     H2OCountedCompleter → Freezable