water

Class H2ONode

java.lang.Object

water.Iced<H2ONode>

water.H2ONode

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, java.lang.Comparable, Freezable<H2ONode>

public final class H2ONode
extends Iced<H2ONode>
implements java.lang.Comparable

A Node in an H2O Cloud. Basically a worker-bee with CPUs, Memory and Disk. One of this is the self-Node, but the rest are remote Nodes.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
HeartBeat	_heartbeat
water.H2ONode.H2Okey	_key
long	_last_heard_from
int	_tcp_readers

Method Summary

Modifier and Type	Method and Description
int	compareTo(java.lang.Object o)
boolean	equals(java.lang.Object o)
java.lang.String	getIpPortString()
H2OSecurityManager	getSecurityManager()
SocketChannelFactory	getSocketFactory()
short	getTimestamp()
int	hashCode()
int	index()
static H2ONode	intern(java.net.InetAddress ip, int port)
int	ip4()
boolean	isClient()
boolean	isHealthy()
boolean	isHealthy(long now)
boolean	isRemovedFromCloud()
static java.nio.channels.ByteChannel	openChan(byte tcpType, SocketChannelFactory socketFactory, java.net.InetAddress originAddr, int originPort, short nodeTimeStamp) Returns a new connection of type tcpType, the type can be either TCPReceiverThread.TCP_SMALL, TCPReceiverThread.TCP_BIG or TCPReceiverThread.TCP_EXTERNAL.
static java.nio.channels.ByteChannel	openChan(byte tcpType, SocketChannelFactory socketFactory, java.lang.String originAddr, int originPort, short nodeTimeStamp)
H2ONode	read_impl(AutoBuffer ab)
H2ONode	readJSON_impl(AutoBuffer ab)
static H2ONode	self(java.net.InetAddress local)
void	sendMessage(java.nio.ByteBuffer bb, byte msg_priority)
java.lang.String	toDebugString()
java.lang.String	toString()
AutoBuffer	write_impl(AutoBuffer ab)
AutoBuffer	writeJSON_impl(AutoBuffer ab)

Methods inherited from class water.Iced

asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonString, write, writeExternal, writeJSON

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

_last_heard_from

public transient long _last_heard_from

_heartbeat

public transient volatile HeartBeat _heartbeat

_tcp_readers

public transient int _tcp_readers

_key

public final water.H2ONode.H2Okey _key

Method Detail

isClient

public final boolean isClient()

getTimestamp

public final short getTimestamp()

isRemovedFromCloud

public final boolean isRemovedFromCloud()

getIpPortString

public java.lang.String getIpPortString()

ip4

public final int ip4()

isHealthy

public boolean isHealthy()

isHealthy

public boolean isHealthy(long now)

intern

public static H2ONode intern(java.net.InetAddress ip,
                             int port)

self

public static H2ONode self(java.net.InetAddress local)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toDebugString

public java.lang.String toDebugString()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

compareTo

public int compareTo(java.lang.Object o)

Specified by:

compareTo in interface java.lang.Comparable

index

public int index()

sendMessage

public final void sendMessage(java.nio.ByteBuffer bb,
                              byte msg_priority)

openChan

public static java.nio.channels.ByteChannel openChan(byte tcpType,
                                                     SocketChannelFactory socketFactory,
                                                     java.net.InetAddress originAddr,
                                                     int originPort,
                                                     short nodeTimeStamp)
                                              throws java.io.IOException

Returns a new connection of type tcpType, the type can be either TCPReceiverThread.TCP_SMALL, TCPReceiverThread.TCP_BIG or TCPReceiverThread.TCP_EXTERNAL. In case of TCPReceiverThread.TCP_EXTERNAL, we need to keep in mind that this method is executed in environment where H2O is not running, but it is just on the classpath so users can establish connection with the external H2O cluster. If socket channel factory is set, the communication will considered to be secured - this depends on the configuration of the SocketChannelFactory. In case of the factory is null, the communication won't be secured.

Returns:

new socket channel

Throws:

java.io.IOException

openChan

public static java.nio.channels.ByteChannel openChan(byte tcpType,
                                                     SocketChannelFactory socketFactory,
                                                     java.lang.String originAddr,
                                                     int originPort,
                                                     short nodeTimeStamp)
                                              throws java.io.IOException

Throws:

java.io.IOException

write_impl

public final AutoBuffer write_impl(AutoBuffer ab)

read_impl

public final H2ONode read_impl(AutoBuffer ab)

writeJSON_impl

public final AutoBuffer writeJSON_impl(AutoBuffer ab)

readJSON_impl

public final H2ONode readJSON_impl(AutoBuffer ab)

getSocketFactory

public SocketChannelFactory getSocketFactory()

getSecurityManager

public H2OSecurityManager getSecurityManager()