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 int[]	EMPTY_ARI
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
static byte	EXPECTED_VECTOR
static boolean	VECTOR_IS_DENSE
static boolean	VECTOR_IS_SPARSE Meta Information used to specify whether we should expect sparse or dense vector

Constructor Summary

Constructors

Constructor and Description
ExternalFrameUtils()

Method Summary

Modifier and Type	Method and Description
static java.nio.channels.ByteChannel	getConnection(java.lang.String h2oNodeHostname, int h2oNodeApiPort, short nodeTimeStamp) Get connection to a specific h2o node.
static java.nio.channels.ByteChannel	getConnection(java.lang.String ipPort, short nodeTimeStamp)
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[]	vecTypesFromExpectedTypes(byte[] expectedTypes, int[] vecElemSizes)
static void	writeToChannel(AutoBuffer ab, java.nio.channels.ByteChannel channel)

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

EXPECTED_VECTOR

public static final byte EXPECTED_VECTOR

See Also:

Constant Field Values

EMPTY_ARI

public static final int[] EMPTY_ARI

VECTOR_IS_SPARSE

public static final boolean VECTOR_IS_SPARSE

Meta Information used to specify whether we should expect sparse or dense vector

See Also:

Constant Field Values

VECTOR_IS_DENSE

public static final boolean VECTOR_IS_DENSE

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,
                                                          short nodeTimeStamp)
                                                   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. This node usually does not have H2O running.

Throws:

java.io.IOException

getConnection

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

Throws:

java.io.IOException

vecTypesFromExpectedTypes

public static byte[] vecTypesFromExpectedTypes(byte[] expectedTypes,
                                               int[] vecElemSizes)

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)

writeToChannel

public static void writeToChannel(AutoBuffer ab,
                                  java.nio.channels.ByteChannel channel)
                           throws java.io.IOException

Throws:

java.io.IOException