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

Methods

Modifier and Type	Method and Description
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()