org.apache.pig.data
Interface InterSedes

All Known Implementing Classes:
BinInterSedes

@InterfaceAudience.Private
@InterfaceStability.Evolving
public interface 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.


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
 void writeDatum(DataOutput out, Object val, byte type)
          Write given object val of DataType type to DataOutput out
 

Method Detail

readDatum

Object readDatum(DataInput in)
                 throws IOException,
                        ExecException
Get the next object from DataInput in

Parameters:
in -
Returns:
Next object from DataInput in
Throws:
IOException
ExecException

readDatum

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

Parameters:
in -
type -
Returns:
Next object from DataInput in
Throws:
IOException
ExecException

addColsToTuple

void addColsToTuple(DataInput in,
                    Tuple t)
                    throws IOException
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

Parameters:
in -
t -
Throws:
IOException

writeDatum

void writeDatum(DataOutput out,
                Object val)
                throws IOException
Write given object val to DataOutput out

Parameters:
out -
val -
Throws:
IOException

writeDatum

void writeDatum(DataOutput out,
                Object val,
                byte type)
                throws IOException
Write given object val of DataType type to DataOutput out

Parameters:
out - output
val - value to write
type - type, as defined in DataType
Throws:
IOException

getTupleRawComparatorClass

Class<? extends TupleRawComparator> getTupleRawComparatorClass()


Copyright © 2007-2012 The Apache Software Foundation