org.apache.pig

Interface LoadCaster

All Known Subinterfaces:

LoadStoreCaster, StoreCaster

All Known Implementing Classes:

AccumuloBinaryConverter, HBaseBinaryConverter, TextLoader, Utf8StorageConverter

@InterfaceAudience.Public
@InterfaceStability.Evolving
public interface LoadCaster

An interface that provides cast implementations for load functions. For casts between bytearray objects and internal types, Pig relies on the load function that loaded the data to provide the cast. This is because Pig does not understand the binary representation of the data and thus cannot cast it. This interface provides functions to cast from bytearray to each of Pig's internal types.

Since:

Pig 0.7

Method Summary

Methods

Modifier and Type	Method and Description
DataBag	bytesToBag(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) Cast data from bytearray to bag value.
java.math.BigDecimal	bytesToBigDecimal(byte[] b) Cast data from bytearray to BigDecimal value.
java.math.BigInteger	bytesToBigInteger(byte[] b) Cast data from bytearray to BigInteger value.
java.lang.Boolean	bytesToBoolean(byte[] b) Cast data from bytearray to boolean value.
java.lang.String	bytesToCharArray(byte[] b) Cast data from bytearray to chararray value.
org.joda.time.DateTime	bytesToDateTime(byte[] b) Cast data from bytearray to datetime value.
java.lang.Double	bytesToDouble(byte[] b) Cast data from bytearray to double value.
java.lang.Float	bytesToFloat(byte[] b) Cast data from bytearray to float value.
java.lang.Integer	bytesToInteger(byte[] b) Cast data from bytearray to integer value.
java.lang.Long	bytesToLong(byte[] b) Cast data from bytearray to long value.
java.util.Map<java.lang.String,java.lang.Object>	bytesToMap(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) Cast data from bytearray to map value.
Tuple	bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) Cast data from bytearray to tuple value.

Method Detail

bytesToBoolean

java.lang.Boolean bytesToBoolean(byte[] b)
                                 throws java.io.IOException

Cast data from bytearray to boolean value.

Parameters:

b - bytearray to be cast.

Returns:

Boolean value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToLong

java.lang.Long bytesToLong(byte[] b)
                           throws java.io.IOException

Cast data from bytearray to long value.

Parameters:

b - bytearray to be cast.

Returns:

Long value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToFloat

java.lang.Float bytesToFloat(byte[] b)
                             throws java.io.IOException

Cast data from bytearray to float value.

Parameters:

b - bytearray to be cast.

Returns:

Float value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToDouble

java.lang.Double bytesToDouble(byte[] b)
                               throws java.io.IOException

Cast data from bytearray to double value.

Parameters:

b - bytearray to be cast.

Returns:

Double value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToDateTime

org.joda.time.DateTime bytesToDateTime(byte[] b)
                                       throws java.io.IOException

Cast data from bytearray to datetime value.

Parameters:

b - bytearray to be cast.

Returns:

datetime value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToInteger

java.lang.Integer bytesToInteger(byte[] b)
                                 throws java.io.IOException

Cast data from bytearray to integer value.

Parameters:

b - bytearray to be cast.

Returns:

Double value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToCharArray

java.lang.String bytesToCharArray(byte[] b)
                                  throws java.io.IOException

Cast data from bytearray to chararray value.

Parameters:

b - bytearray to be cast.

Returns:

String value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToMap

java.util.Map<java.lang.String,java.lang.Object> bytesToMap(byte[] b,
                                                          ResourceSchema.ResourceFieldSchema fieldSchema)
                                                            throws java.io.IOException

Cast data from bytearray to map value.

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output map

Returns:

Map value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToTuple

Tuple bytesToTuple(byte[] b,
                 ResourceSchema.ResourceFieldSchema fieldSchema)
                   throws java.io.IOException

Cast data from bytearray to tuple value.

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output tuple

Returns:

Tuple value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToBag

DataBag bytesToBag(byte[] b,
                 ResourceSchema.ResourceFieldSchema fieldSchema)
                   throws java.io.IOException

Cast data from bytearray to bag value.

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output bag

Returns:

Bag value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToBigInteger

java.math.BigInteger bytesToBigInteger(byte[] b)
                                       throws java.io.IOException

Cast data from bytearray to BigInteger value.

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output bag

Returns:

BigInteger value.

Throws:

java.io.IOException - if the value cannot be cast.

bytesToBigDecimal

java.math.BigDecimal bytesToBigDecimal(byte[] b)
                                       throws java.io.IOException

Cast data from bytearray to BigDecimal value.

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output bag

Returns:

BigInteger value.

Throws:

java.io.IOException - if the value cannot be cast.