water

Class ExternalFrameUtils

java.lang.Object

water.ExternalFrameUtils

public class ExternalFrameUtils
extends java.lang.Object

Various utilities methods to help with external frame handling.

Field Summary

Fields

Modifier and Type	Field and Description
static byte	EXPECTED_BOOL Hints for expected types in order to improve performance network communication.
static byte	EXPECTED_BYTE
static byte	EXPECTED_CHAR
static byte	EXPECTED_DOUBLE
static byte	EXPECTED_FLOAT
static byte	EXPECTED_INT
static byte	EXPECTED_LONG
static byte	EXPECTED_SHORT
static byte	EXPECTED_STRING
static byte	EXPECTED_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
ExternalFrameUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static java.nio.channels.ByteChannel	getConnection(java.lang.String ipPort)
static java.nio.channels.ByteChannel	getConnection(java.lang.String h2oNodeHostname, int h2oNodeApiPort) Get connection to a specific h2o node.
static boolean	isNA(AutoBuffer ab, boolean data)
static boolean	isNA(AutoBuffer ab, long data)
static boolean	isNA(AutoBuffer ab, java.lang.String data)
static boolean	isNA(AutoBuffer ab, java.sql.Timestamp data)
static boolean	isNA(double data)
static byte[]	prepareExpectedTypes(java.lang.Class[] javaClasses)
static byte[]	vecTypesFromExpectedTypes(byte[] expectedTypes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EXPECTED_BOOL

public static final byte EXPECTED_BOOL

Hints for expected types in order to improve performance network communication. We make use of these to send and receive data we actually have. Each supported type for conversion has to be specified here

See Also:

Constant Field Values

EXPECTED_BYTE

public static final byte EXPECTED_BYTE

See Also:

Constant Field Values

EXPECTED_CHAR

public static final byte EXPECTED_CHAR

See Also:

Constant Field Values

EXPECTED_SHORT

public static final byte EXPECTED_SHORT

See Also:

Constant Field Values

EXPECTED_INT

public static final byte EXPECTED_INT

See Also:

Constant Field Values

EXPECTED_FLOAT

public static final byte EXPECTED_FLOAT

See Also:

Constant Field Values

EXPECTED_LONG

public static final byte EXPECTED_LONG

See Also:

Constant Field Values

EXPECTED_DOUBLE

public static final byte EXPECTED_DOUBLE

See Also:

Constant Field Values

EXPECTED_STRING

public static final byte EXPECTED_STRING

See Also:

Constant Field Values

EXPECTED_TIMESTAMP

public static final byte EXPECTED_TIMESTAMP

See Also:

Constant Field Values

Constructor Detail

ExternalFrameUtils

public ExternalFrameUtils()

Method Detail

getConnection

public static java.nio.channels.ByteChannel getConnection(java.lang.String h2oNodeHostname,
                                          int h2oNodeApiPort)
                                                   throws java.io.IOException

Get connection to a specific h2o node. The caller of this method is usually non-H2O node who wants to read H2O frames or write to H2O frames from non-H2O environment, such as Spark executor.

Throws:

java.io.IOException

getConnection

public static java.nio.channels.ByteChannel getConnection(java.lang.String ipPort)
                                                   throws java.io.IOException

Throws:

java.io.IOException

vecTypesFromExpectedTypes

public static byte[] vecTypesFromExpectedTypes(byte[] expectedTypes)

prepareExpectedTypes

public static byte[] prepareExpectedTypes(java.lang.Class[] javaClasses)

isNA

public static boolean isNA(AutoBuffer ab,
           boolean data)

isNA

public static boolean isNA(AutoBuffer ab,
           long data)

isNA

public static boolean isNA(double data)

isNA

public static boolean isNA(AutoBuffer ab,
           java.sql.Timestamp data)

isNA

public static boolean isNA(AutoBuffer ab,
           java.lang.String data)