org.apache.pig.data
Class BinInterSedes

java.lang.Object
  extended by org.apache.pig.data.BinInterSedes
All Implemented Interfaces:
InterSedes

@InterfaceAudience.Private
@InterfaceStability.Stable
public class BinInterSedes
extends Object
implements InterSedes

A class to handle reading and writing of intermediate results of data types. The serialization format used by this class more efficient than what was used in DataReaderWriter . The format used by the functions in this class is subject to change, so it should be used ONLY to store intermediate results within a pig query.


Nested Class Summary
static class BinInterSedes.BinInterSedesTupleRawComparator
           
 
Field Summary
static byte BAG
           
static byte BOOLEAN_FALSE
           
static byte BOOLEAN_TRUE
           
static byte BYTE
           
static byte BYTEARRAY
           
static byte CHARARRAY
           
static byte DOUBLE
           
static byte FLOAT
           
static byte GENERIC_WRITABLECOMPARABLE
           
static byte INTEGER
           
static byte INTEGER_0
           
static byte INTEGER_1
           
static byte INTEGER_INBYTE
           
static byte INTEGER_INSHORT
           
static byte INTERNALMAP
           
static byte LONG
           
static byte MAP
           
static byte NULL
           
static byte SMALLBAG
           
static byte SMALLBYTEARRAY
           
static byte SMALLCHARARRAY
           
static byte SMALLMAP
           
static byte SMALLTUPLE
           
static byte TINYBAG
           
static byte TINYBYTEARRAY
           
static byte TINYMAP
           
static byte TINYTUPLE
           
static byte TUPLE
           
static String UTF8
           
 
Constructor Summary
BinInterSedes()
           
 
Method Summary
 void addColsToTuple(DataInput in, Tuple t)
          The type of next object has been determined to be of type Tuple, add the columns that belong to the tuple to given tuple argument t
 Class<? extends TupleRawComparator> getTupleRawComparatorClass()
           
 Object readDatum(DataInput in)
          Get the next object from DataInput in
 Object readDatum(DataInput in, byte type)
          Get the next object from DataInput in of the type of type argument The type information has been read from DataInput.
 void writeDatum(DataOutput out, Object val)
          Write given object val to DataOutput out
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

BOOLEAN_TRUE

public static final byte BOOLEAN_TRUE
See Also:
Constant Field Values

BOOLEAN_FALSE

public static final byte BOOLEAN_FALSE
See Also:
Constant Field Values

BYTE

public static final byte BYTE
See Also:
Constant Field Values

INTEGER

public static final byte INTEGER
See Also:
Constant Field Values

INTEGER_0

public static final byte INTEGER_0
See Also:
Constant Field Values

INTEGER_1

public static final byte INTEGER_1
See Also:
Constant Field Values

INTEGER_INSHORT

public static final byte INTEGER_INSHORT
See Also:
Constant Field Values

INTEGER_INBYTE

public static final byte INTEGER_INBYTE
See Also:
Constant Field Values

LONG

public static final byte LONG
See Also:
Constant Field Values

FLOAT

public static final byte FLOAT
See Also:
Constant Field Values

DOUBLE

public static final byte DOUBLE
See Also:
Constant Field Values

BYTEARRAY

public static final byte BYTEARRAY
See Also:
Constant Field Values

SMALLBYTEARRAY

public static final byte SMALLBYTEARRAY
See Also:
Constant Field Values

TINYBYTEARRAY

public static final byte TINYBYTEARRAY
See Also:
Constant Field Values

CHARARRAY

public static final byte CHARARRAY
See Also:
Constant Field Values

SMALLCHARARRAY

public static final byte SMALLCHARARRAY
See Also:
Constant Field Values

MAP

public static final byte MAP
See Also:
Constant Field Values

SMALLMAP

public static final byte SMALLMAP
See Also:
Constant Field Values

TINYMAP

public static final byte TINYMAP
See Also:
Constant Field Values

TUPLE

public static final byte TUPLE
See Also:
Constant Field Values

SMALLTUPLE

public static final byte SMALLTUPLE
See Also:
Constant Field Values

TINYTUPLE

public static final byte TINYTUPLE
See Also:
Constant Field Values

BAG

public static final byte BAG
See Also:
Constant Field Values

SMALLBAG

public static final byte SMALLBAG
See Also:
Constant Field Values

TINYBAG

public static final byte TINYBAG
See Also:
Constant Field Values

GENERIC_WRITABLECOMPARABLE

public static final byte GENERIC_WRITABLECOMPARABLE
See Also:
Constant Field Values

INTERNALMAP

public static final byte INTERNALMAP
See Also:
Constant Field Values

NULL

public static final byte NULL
See Also:
Constant Field Values

UTF8

public static final String UTF8
See Also:
Constant Field Values
Constructor Detail

BinInterSedes

public BinInterSedes()
Method Detail

readDatum

public Object readDatum(DataInput in)
                 throws IOException,
                        ExecException
Description copied from interface: InterSedes
Get the next object from DataInput in

Specified by:
readDatum in interface InterSedes
Returns:
Next object from DataInput in
Throws:
IOException
ExecException

readDatum

public Object readDatum(DataInput in,
                        byte type)
                 throws IOException,
                        ExecException
Description copied from interface: InterSedes
Get the next object from DataInput in of the type of type argument The type information has been read from DataInput.

Specified by:
readDatum in interface InterSedes
Returns:
Next object from DataInput in
Throws:
IOException
ExecException

writeDatum

public void writeDatum(DataOutput out,
                       Object val)
                throws IOException
Description copied from interface: InterSedes
Write given object val to DataOutput out

Specified by:
writeDatum in interface InterSedes
Throws:
IOException

addColsToTuple

public void addColsToTuple(DataInput in,
                           Tuple t)
                    throws IOException
Description copied from interface: InterSedes
The type of next object has been determined to be of type Tuple, add the columns that belong to the tuple to given tuple argument t

Specified by:
addColsToTuple in interface InterSedes
Throws:
IOException

getTupleRawComparatorClass

public Class<? extends TupleRawComparator> getTupleRawComparatorClass()
Specified by:
getTupleRawComparatorClass in interface InterSedes


Copyright © ${year} The Apache Software Foundation