org.apache.pig.builtin

Class Utf8StorageConverter

java.lang.Object

org.apache.pig.builtin.Utf8StorageConverter

All Implemented Interfaces:

LoadCaster, LoadStoreCaster, StoreCaster

public class Utf8StorageConverter
extends Object
implements LoadStoreCaster

This abstract class provides standard conversions between utf8 encoded data and pig data types. It is intended to be extended by load and store functions (such as PigStorage).

Field Summary

Fields

Modifier and Type	Field and Description
protected BagFactory	mBagFactory
protected org.apache.commons.logging.Log	mLog
protected TupleFactory	mTupleFactory

Constructor Summary

Constructors

Constructor and Description
Utf8StorageConverter()

Method Summary

Modifier and Type	Method and Description
DataBag	bytesToBag(byte[] b, ResourceSchema.ResourceFieldSchema schema) Cast data from bytearray to bag value.
BigDecimal	bytesToBigDecimal(byte[] b) Cast data from bytearray to BigDecimal value.
BigInteger	bytesToBigInteger(byte[] b) Cast data from bytearray to BigInteger value.
Boolean	bytesToBoolean(byte[] b) Cast data from bytearray to boolean value.
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.
Double	bytesToDouble(byte[] b) Cast data from bytearray to double value.
Float	bytesToFloat(byte[] b) Cast data from bytearray to float value.
Integer	bytesToInteger(byte[] b) Cast data from bytearray to integer value.
Long	bytesToLong(byte[] b) Cast data from bytearray to long value.
Map<String,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.
byte[]	toBytes(BigDecimal bd)
byte[]	toBytes(BigInteger bi)
byte[]	toBytes(Boolean b)
byte[]	toBytes(DataBag bag)
byte[]	toBytes(DataByteArray a)
byte[]	toBytes(org.joda.time.DateTime dt)
byte[]	toBytes(Double d)
byte[]	toBytes(Float f)
byte[]	toBytes(Integer i)
byte[]	toBytes(Long l)
byte[]	toBytes(Map<String,Object> m)
byte[]	toBytes(String s)
byte[]	toBytes(Tuple t)

Methods inherited from class java.lang.Object

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

Field Detail

mBagFactory

protected BagFactory mBagFactory

mTupleFactory

protected TupleFactory mTupleFactory

mLog

protected final org.apache.commons.logging.Log mLog

Constructor Detail

Utf8StorageConverter

public Utf8StorageConverter()

Method Detail

bytesToBag

public DataBag bytesToBag(byte[] b,
                          ResourceSchema.ResourceFieldSchema schema)
                   throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to bag value.

Specified by:

bytesToBag in interface LoadCaster

Parameters:

b - bytearray to be cast.

schema - field schema for the output bag

Returns:

Bag value.

Throws:

IOException - if the value cannot be cast.

bytesToCharArray

public String bytesToCharArray(byte[] b)
                        throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to chararray value.

Specified by:

bytesToCharArray in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

String value.

Throws:

IOException - if the value cannot be cast.

bytesToDouble

public Double bytesToDouble(byte[] b)

Description copied from interface: LoadCaster

Cast data from bytearray to double value.

Specified by:

bytesToDouble in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

Double value.

bytesToFloat

public Float bytesToFloat(byte[] b)
                   throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to float value.

Specified by:

bytesToFloat in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

Float value.

Throws:

IOException - if the value cannot be cast.

bytesToBoolean

public Boolean bytesToBoolean(byte[] b)
                       throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to boolean value.

Specified by:

bytesToBoolean in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

Boolean value.

Throws:

IOException - if the value cannot be cast.

bytesToInteger

public Integer bytesToInteger(byte[] b)
                       throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to integer value.

Specified by:

bytesToInteger in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

Double value.

Throws:

IOException - if the value cannot be cast.

bytesToLong

public Long bytesToLong(byte[] b)
                 throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to long value.

Specified by:

bytesToLong in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

Long value.

Throws:

IOException - if the value cannot be cast.

bytesToDateTime

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

Description copied from interface: LoadCaster

Cast data from bytearray to datetime value.

Specified by:

bytesToDateTime in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

datetime value.

Throws:

IOException - if the value cannot be cast.

bytesToMap

public Map<String,Object> bytesToMap(byte[] b,
                                     ResourceSchema.ResourceFieldSchema fieldSchema)
                              throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to map value.

Specified by:

bytesToMap in interface LoadCaster

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output map

Returns:

Map value.

Throws:

IOException - if the value cannot be cast.

bytesToTuple

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

Description copied from interface: LoadCaster

Cast data from bytearray to tuple value.

Specified by:

bytesToTuple in interface LoadCaster

Parameters:

b - bytearray to be cast.

fieldSchema - field schema for the output tuple

Returns:

Tuple value.

Throws:

IOException - if the value cannot be cast.

bytesToBigInteger

public BigInteger bytesToBigInteger(byte[] b)
                             throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to BigInteger value.

Specified by:

bytesToBigInteger in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

BigInteger value.

Throws:

IOException - if the value cannot be cast.

bytesToBigDecimal

public BigDecimal bytesToBigDecimal(byte[] b)
                             throws IOException

Description copied from interface: LoadCaster

Cast data from bytearray to BigDecimal value.

Specified by:

bytesToBigDecimal in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

BigInteger value.

Throws:

IOException - if the value cannot be cast.

toBytes

public byte[] toBytes(DataBag bag)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(String s)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Double d)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Float f)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Integer i)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Long l)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Boolean b)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(org.joda.time.DateTime dt)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Map<String,Object> m)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(Tuple t)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(DataByteArray a)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(BigInteger bi)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException

toBytes

public byte[] toBytes(BigDecimal bd)
               throws IOException

Specified by:

toBytes in interface StoreCaster

Throws:

IOException