Method getSplitComparable

src/org/apache/pig/FileInputLoadFunc.java:38–52

(InputSplit split)

public abstract class FileInputLoadFunc extends LoadFunc implements OrderedLoadFunc  {
    
    @Override
    public WritableComparable<?> getSplitComparable(InputSplit split)
    throws IOException{
        FileSplit fileSplit = null;
        if(split instanceof FileSplit){
            fileSplit = (FileSplit)split;
        }else{
            throw new RuntimeException("LoadFunc expected split of type FileSplit");
        }
        
        return new FileSplitComparable(
                fileSplit.getPath().toString(),
                fileSplit.getStart()
        );
    }

}