org.apache.pig.backend.hadoop.accumulo

Class AccumuloBinaryConverter

java.lang.Object

org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter

All Implemented Interfaces:

LoadCaster, LoadStoreCaster, StoreCaster

public class AccumuloBinaryConverter
extends java.lang.Object
implements LoadStoreCaster

A LoadStoreCaster implementation which stores most type implementations as bytes generated from the toString representation with a UTF8 Charset. Pulled some implementations from the Accumulo Lexicoder implementations in 1.6.0.

Constructor Summary

Constructors

Constructor and Description
AccumuloBinaryConverter()

Method Summary

Modifier and Type	Method and Description
DataBag	bytesToBag(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) NOT IMPLEMENTED
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) NOT IMPLEMENTED
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) NOT IMPLEMENTED
Tuple	bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) NOT IMPLEMENTED
byte[]	toBytes(java.math.BigDecimal bd) Not implemented!
byte[]	toBytes(java.math.BigInteger bi)
byte[]	toBytes(java.lang.Boolean b)
byte[]	toBytes(DataBag bag) NOT IMPLEMENTED
byte[]	toBytes(DataByteArray a)
byte[]	toBytes(org.joda.time.DateTime dt)
byte[]	toBytes(java.lang.Double d)
byte[]	toBytes(java.lang.Float f)
byte[]	toBytes(java.lang.Integer val)
byte[]	toBytes(java.lang.Long val)
byte[]	toBytes(java.util.Map<java.lang.String,java.lang.Object> m) NOT IMPLEMENTED
byte[]	toBytes(java.lang.String s)
byte[]	toBytes(Tuple t) NOT IMPLEMENTED

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloBinaryConverter

public AccumuloBinaryConverter()

Method Detail

bytesToBag

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

NOT IMPLEMENTED

Specified by:

bytesToBag in interface LoadCaster

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.

bytesToBigDecimal

public java.math.BigDecimal bytesToBigDecimal(byte[] b)
                                       throws java.io.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:

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

bytesToBigInteger

public java.math.BigInteger bytesToBigInteger(byte[] b)
                                       throws java.io.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:

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

bytesToBoolean

public java.lang.Boolean bytesToBoolean(byte[] b)
                                 throws java.io.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:

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

bytesToCharArray

public java.lang.String bytesToCharArray(byte[] b)
                                  throws java.io.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:

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

bytesToDateTime

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

NOT IMPLEMENTED

Specified by:

bytesToDateTime in interface LoadCaster

Parameters:

b - bytearray to be cast.

Returns:

datetime value.

Throws:

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

bytesToDouble

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

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.

Throws:

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

bytesToFloat

public java.lang.Float bytesToFloat(byte[] b)
                             throws java.io.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:

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

bytesToInteger

public java.lang.Integer bytesToInteger(byte[] b)
                                 throws java.io.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:

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

bytesToLong

public java.lang.Long bytesToLong(byte[] b)
                           throws java.io.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:

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

bytesToMap

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

NOT IMPLEMENTED

Specified by:

bytesToMap in interface LoadCaster

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

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

NOT IMPLEMENTED

Specified by:

bytesToTuple in interface LoadCaster

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.

toBytes

public byte[] toBytes(java.math.BigDecimal bd)
               throws java.io.IOException

Not implemented!

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.math.BigInteger bi)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

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

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(DataBag bag)
               throws java.io.IOException

NOT IMPLEMENTED

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(DataByteArray a)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

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

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.lang.Double d)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.lang.Float f)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.lang.Integer val)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.lang.Long val)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.util.Map<java.lang.String,java.lang.Object> m)
               throws java.io.IOException

NOT IMPLEMENTED

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(java.lang.String s)
               throws java.io.IOException

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException

toBytes

public byte[] toBytes(Tuple t)
               throws java.io.IOException

NOT IMPLEMENTED

Specified by:

toBytes in interface StoreCaster

Throws:

java.io.IOException