org.apache.pig

Class FileInputLoadFunc

java.lang.Object

org.apache.pig.LoadFunc

org.apache.pig.FileInputLoadFunc

All Implemented Interfaces:

OrderedLoadFunc

Direct Known Subclasses:

AllLoader, AvroStorage, BinStorage, CSVLoader, HiveColumnarLoader, InterStorage, PigStorage, SequenceFileInterStorage, SequenceFileLoader, TFileStorage

@InterfaceAudience.Public
@InterfaceStability.Evolving
public abstract class FileInputLoadFunc
extends LoadFunc
implements OrderedLoadFunc

This class provides an implementation of OrderedLoadFunc interface which can be optionally re-used by LoadFuncs that use FileInputFormat, by having this as a super class

Since:

Pig 0.7

Constructor Summary

Constructors

Constructor and Description
FileInputLoadFunc()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.io.WritableComparable<?>	getSplitComparable(org.apache.hadoop.mapreduce.InputSplit split) The WritableComparable object returned will be used to compare the position of different splits in an ordered stream

Methods inherited from class org.apache.pig.LoadFunc

getAbsolutePath, getCacheFiles, getInputFormat, getLoadCaster, getNext, getPathStrings, getShipFiles, join, prepareToRead, relativeToAbsolutePath, setLocation, setUDFContextSignature, warn

Methods inherited from class java.lang.Object

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

Constructor Detail

FileInputLoadFunc

public FileInputLoadFunc()

Method Detail

getSplitComparable

public org.apache.hadoop.io.WritableComparable<?> getSplitComparable(org.apache.hadoop.mapreduce.InputSplit split)
                                                              throws java.io.IOException

Description copied from interface: OrderedLoadFunc

The WritableComparable object returned will be used to compare the position of different splits in an ordered stream

Specified by:

getSplitComparable in interface OrderedLoadFunc

Parameters:

split - An InputSplit from the InputFormat underlying this loader.

Returns:

WritableComparable representing the position of the split in input

Throws:

java.io.IOException