org.apache.pig.builtin

Class ParquetStorer

java.lang.Object

org.apache.pig.StoreFuncWrapper

org.apache.pig.StoreFuncMetadataWrapper

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

Constructors

Constructor and Description
ParquetStorer()

Method Summary

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