org.apache.pig.builtin
Class ParquetStorer

java.lang.Object
  extended by org.apache.pig.StoreFuncWrapper
      extended by org.apache.pig.StoreFuncMetadataWrapper
          extended by org.apache.pig.builtin.ParquetStorer
All Implemented Interfaces:
StoreFuncInterface, StoreMetadata

public class ParquetStorer
extends StoreFuncMetadataWrapper

Wrapper class which will delegate calls to parquet.pig.ParquetStorer


Constructor Summary
ParquetStorer()
           
 
Method Summary
 void setStoreLocation(String location, org.apache.hadoop.mapreduce.Job job)
          Communicate to the storer the location where the data needs to be stored.
 
Methods inherited from class org.apache.pig.StoreFuncMetadataWrapper
setStoreFunc, storeSchema, storeStatistics
 
Methods inherited from class org.apache.pig.StoreFuncWrapper
checkSchema, cleanupOnFailure, cleanupOnSuccess, getMethodName, getOutputFormat, prepareToWrite, putNext, relToAbsPathForStoreLocation, setStoreFunc, setStoreFuncUDFContextSignature
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ParquetStorer

public ParquetStorer()
              throws FrontendException
Throws:
FrontendException
Method Detail

setStoreLocation

public void setStoreLocation(String location,
                             org.apache.hadoop.mapreduce.Job job)
                      throws IOException
Communicate to the storer the location where the data needs to be stored. The location string passed to the StoreFuncInterface here is the return value of StoreFuncInterface.relToAbsPathForStoreLocation(String, Path) This method will be called in the frontend and backend multiple times. Implementations should bear in mind that this method is called multiple times and should ensure there are no inconsistent side effects due to the multiple calls. StoreFuncInterface.checkSchema(ResourceSchema) will be called before any call to StoreFuncInterface.setStoreLocation(String, Job).

Specified by:
setStoreLocation in interface StoreFuncInterface
Overrides:
setStoreLocation in class StoreFuncWrapper
Parameters:
location - Location returned by StoreFuncInterface.relToAbsPathForStoreLocation(String, Path)
job - The Job object
Throws:
IOException - if the location is not valid.


Copyright © 2007-2012 The Apache Software Foundation