org.apache.pig.data

Class DataReaderWriter

java.lang.Object

org.apache.pig.data.DataReaderWriter

@InterfaceAudience.Private
 @InterfaceStability.Stable
public class DataReaderWriter
extends java.lang.Object

This class was used to handle reading and writing of intermediate results of data types. Now that functionality is in BinInterSedes This class could also be used for storing permanent results, it used by BinStorage through DefaultTuple class.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	UTF8

Constructor Summary

Constructors

Constructor and Description
DataReaderWriter()

Method Summary

Modifier and Type	Method and Description
static DataBag	bytesToBag(java.io.DataInput in)
static java.lang.String	bytesToBigCharArray(java.io.DataInput in)
static java.lang.String	bytesToCharArray(java.io.DataInput in)
static InternalMap	bytesToInternalMap(java.io.DataInput in)
static java.util.Map<java.lang.String,java.lang.Object>	bytesToMap(java.io.DataInput in)
static Tuple	bytesToTuple(java.io.DataInput in)
static org.apache.hadoop.io.Writable	bytesToWritable(java.io.DataInput in)
static java.lang.Object	readDatum(java.io.DataInput in)
static java.lang.Object	readDatum(java.io.DataInput in, byte type)
static void	writeDatum(java.io.DataOutput out, java.lang.Object val)

Methods inherited from class java.lang.Object

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

Field Detail

UTF8

public static final java.lang.String UTF8

See Also:

Constant Field Values

Constructor Detail

DataReaderWriter

public DataReaderWriter()

Method Detail

bytesToTuple

public static Tuple bytesToTuple(java.io.DataInput in)
                          throws java.io.IOException

Throws:

java.io.IOException

bytesToBag

public static DataBag bytesToBag(java.io.DataInput in)
                          throws java.io.IOException

Throws:

java.io.IOException

bytesToMap

public static java.util.Map<java.lang.String,java.lang.Object> bytesToMap(java.io.DataInput in)
                                                                   throws java.io.IOException

Throws:

java.io.IOException

bytesToInternalMap

public static InternalMap bytesToInternalMap(java.io.DataInput in)
                                      throws java.io.IOException

Throws:

java.io.IOException

bytesToCharArray

public static java.lang.String bytesToCharArray(java.io.DataInput in)
                                         throws java.io.IOException

Throws:

java.io.IOException

bytesToBigCharArray

public static java.lang.String bytesToBigCharArray(java.io.DataInput in)
                                            throws java.io.IOException

Throws:

java.io.IOException

bytesToWritable

public static org.apache.hadoop.io.Writable bytesToWritable(java.io.DataInput in)
                                                     throws java.io.IOException

Throws:

java.io.IOException

readDatum

public static java.lang.Object readDatum(java.io.DataInput in)
                                  throws java.io.IOException,
                                         ExecException

Throws:

java.io.IOException

ExecException

readDatum

public static java.lang.Object readDatum(java.io.DataInput in,
                                         byte type)
                                  throws java.io.IOException,
                                         ExecException

Throws:

java.io.IOException

ExecException

writeDatum

public static void writeDatum(java.io.DataOutput out,
                              java.lang.Object val)
                       throws java.io.IOException

Throws:

java.io.IOException