H2ORpcEndpoint

class H2ORpcEndpoint extends ThreadSafeRpcEndpoint

An RpcEndpoint used for communication between H2O client and H2O worker nodes on remote executors. This endpoint is started on each Spark executor where H2O worker will be running.

Linear Supertypes

ThreadSafeRpcEndpoint, RpcEndpoint, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

H2ORpcEndpoint
ThreadSafeRpcEndpoint
RpcEndpoint
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new H2ORpcEndpoint(rpcEnv: RpcEnv)

Value Members

final def !=(arg0: Any): Boolean

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

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
def onConnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onDisconnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onError(cause: Throwable): Unit

Definition Classes
RpcEndpoint
def onNetworkError(cause: Throwable, remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onStart(): Unit

Definition Classes
RpcEndpoint
def onStop(): Unit

Definition Classes
RpcEndpoint
def receive: PartialFunction[Any, Unit]

Definition Classes
H2ORpcEndpoint → RpcEndpoint
def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit]

Definition Classes
H2ORpcEndpoint → RpcEndpoint
val rpcEnv: RpcEnv

Definition Classes
H2ORpcEndpoint → RpcEndpoint
final def self: RpcEndpointRef

Definition Classes
RpcEndpoint
final def stop(): Unit

Definition Classes
RpcEndpoint
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()

Inherited from RpcEndpoint

Value Members

def onConnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onDisconnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onError(cause: Throwable): Unit

Definition Classes
RpcEndpoint
def onNetworkError(cause: Throwable, remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onStart(): Unit

Definition Classes
RpcEndpoint
def onStop(): Unit

Definition Classes
RpcEndpoint
final def self: RpcEndpointRef

Definition Classes
RpcEndpoint
final def stop(): Unit

Definition Classes
RpcEndpoint

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean

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

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0

Definition Classes
Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any

Ungrouped

final def !=(arg0: Any): Boolean

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

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
def onConnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onDisconnected(remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onError(cause: Throwable): Unit

Definition Classes
RpcEndpoint
def onNetworkError(cause: Throwable, remoteAddress: RpcAddress): Unit

Definition Classes
RpcEndpoint
def onStart(): Unit

Definition Classes
RpcEndpoint
def onStop(): Unit

Definition Classes
RpcEndpoint
def receive: PartialFunction[Any, Unit]

Definition Classes
H2ORpcEndpoint → RpcEndpoint
def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit]

Definition Classes
H2ORpcEndpoint → RpcEndpoint
val rpcEnv: RpcEnv

Definition Classes
H2ORpcEndpoint → RpcEndpoint
final def self: RpcEndpointRef

Definition Classes
RpcEndpoint
final def stop(): Unit

Definition Classes
RpcEndpoint
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()

Packages

H2ORpcEndpoint 

class H2ORpcEndpoint extends ThreadSafeRpcEndpoint

Instance Constructors

Value Members

Inherited from RpcEndpoint

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

H2ORpcEndpoint