org.archive.hadoop

Class ArchiveMetadataLoader

java.lang.Object

org.apache.pig.LoadFunc

org.apache.pig.FileInputLoadFunc

org.archive.hadoop.ArchiveMetadataLoader

All Implemented Interfaces:

org.apache.pig.OrderedLoadFunc

Direct Known Subclasses:

ArchiveJSONViewLoader

public class ArchiveMetadataLoader
extends org.apache.pig.FileInputLoadFunc

Pig Storage Loader for Archive meta data.

Author:

brad

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.pig.data.TupleFactory	mTupleFactory

Constructor Summary

Constructors

Constructor and Description
ArchiveMetadataLoader()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.InputFormat	getInputFormat()
org.apache.pig.data.Tuple	getNext()
void	prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit arg1)
void	setLocation(java.lang.String location, org.apache.hadoop.mapreduce.Job job)

Methods inherited from class org.apache.pig.FileInputLoadFunc

getSplitComparable

Methods inherited from class org.apache.pig.LoadFunc

getAbsolutePath, getLoadCaster, getPathStrings, join, relativeToAbsolutePath, setUDFContextSignature, warn

Methods inherited from class java.lang.Object

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

Field Detail

mTupleFactory

protected org.apache.pig.data.TupleFactory mTupleFactory

Constructor Detail

ArchiveMetadataLoader

public ArchiveMetadataLoader()

Method Detail

getInputFormat

public org.apache.hadoop.mapreduce.InputFormat getInputFormat()
                                                       throws java.io.IOException

Specified by:

getInputFormat in class org.apache.pig.LoadFunc

Throws:

java.io.IOException

getNext

public org.apache.pig.data.Tuple getNext()
                                  throws java.io.IOException

Specified by:

getNext in class org.apache.pig.LoadFunc

Throws:

java.io.IOException

prepareToRead

public void prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
                          org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit arg1)
                   throws java.io.IOException

Specified by:

prepareToRead in class org.apache.pig.LoadFunc

Throws:

java.io.IOException

setLocation

public void setLocation(java.lang.String location,
                        org.apache.hadoop.mapreduce.Job job)
                 throws java.io.IOException

Specified by:

setLocation in class org.apache.pig.LoadFunc

Throws:

java.io.IOException