Class ParquetStorer

  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
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


public ParquetStorer()
              throws FrontendException
Method Detail


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
setStoreLocation in class StoreFuncWrapper
location - Location returned by StoreFuncInterface.relToAbsPathForStoreLocation(String, Path)
job - The Job object
IOException - if the location is not valid.

Copyright © 2007-2012 The Apache Software Foundation