co.cask.cdap.data2.dataset2.lib.partitioned

Class FieldTypes

java.lang.Object

co.cask.cdap.data2.dataset2.lib.partitioned.FieldTypes

public class FieldTypes
extends Object

Common utility methods when dealing wit partitioning field types.

Constructor Summary

Constructors

Constructor and Description
FieldTypes()

Method Summary

Methods

Modifier and Type	Method and Description
static int	determineLengthInBytes(byte[] bytes, int offset, co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)
static <T extends Comparable> T	fromBytes(byte[] bytes, int offset, int length, co.cask.cdap.api.dataset.lib.Partitioning.FieldType type) Deserialize a value of this field type, starting at given offset in the byte array, consuming the given number of bytes.
static <T extends Comparable> T	parse(String str, co.cask.cdap.api.dataset.lib.Partitioning.FieldType type) Parse a string into a value of this field type.
static <T extends Comparable> byte[]	toBytes(T value, co.cask.cdap.api.dataset.lib.Partitioning.FieldType type) Convert a value of this field type to a byte array.
static String	toHiveType(co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)
static boolean	validateType(Comparable value, co.cask.cdap.api.dataset.lib.Partitioning.FieldType type) Validate that a given value has the type that is required by this field type.

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldTypes

public FieldTypes()

Method Detail

parse

public static <T extends Comparable> T parse(String str,
                             co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Parse a string into a value of this field type. For example, Partitioning.FieldType.INT delegates this to Integer.parseInt(java.lang.String, int).

Parameters:

str - the string to parse

toBytes

public static <T extends Comparable> byte[] toBytes(T value,
                                    co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Convert a value of this field type to a byte array.

Type Parameters:

T - the Java type represented by this field type

Parameters:

value - the value to convert

determineLengthInBytes

public static int determineLengthInBytes(byte[] bytes,
                         int offset,
                         co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Returns:

the number of bytes that need to be read to deserialize a value of this field type at the given position in the byte array. For integer and long values, this is constant, but for strings, this is variable depending on the length of the string.

fromBytes

public static <T extends Comparable> T fromBytes(byte[] bytes,
                                 int offset,
                                 int length,
                                 co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Deserialize a value of this field type, starting at given offset in the byte array, consuming the given number of bytes.

validateType

public static boolean validateType(Comparable value,
                   co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Validate that a given value has the type that is required by this field type.

toHiveType

public static String toHiveType(co.cask.cdap.api.dataset.lib.Partitioning.FieldType type)

Returns:

the type name used by the Hive DDL to represent this field type