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
    Description
    protected org.apache.pig.data.TupleFactory
    mTupleFactory
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ArchiveMetadataLoader()
     

  • Method Summary

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

    addCredentials, getAbsolutePath, getCacheFiles, getGlobPaths, getLoadCaster, getPathStrings, getShipFiles, join, relativeToAbsolutePath, setUDFContextSignature, warn

    Methods inherited from class java.lang.Object

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

  • Field Details

    • mTupleFactory

      protected org.apache.pig.data.TupleFactory mTupleFactory

  • Constructor Details

    • ArchiveMetadataLoader

      public ArchiveMetadataLoader()

  • Method Details

    • getInputFormat

      public org.apache.hadoop.mapreduce.InputFormat getInputFormat() throws IOException
      Specified by:
      getInputFormat in class org.apache.pig.LoadFunc
      Throws:
      IOException

    • getNext

      public org.apache.pig.data.Tuple getNext() throws IOException
      Specified by:
      getNext in class org.apache.pig.LoadFunc
      Throws:
      IOException

    • prepareToRead

      public void prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit arg1) throws IOException
      Specified by:
      prepareToRead in class org.apache.pig.LoadFunc
      Throws:
      IOException

    • setLocation

      public void setLocation(String location, org.apache.hadoop.mapreduce.Job job) throws IOException
      Specified by:
      setLocation in class org.apache.pig.LoadFunc
      Throws:
      IOException