org.apache.pig

Class StoreFuncMetadataWrapper

java.lang.Object

org.apache.pig.StoreFuncWrapper

org.apache.pig.StoreFuncMetadataWrapper

All Implemented Interfaces:

StoreFuncInterface, StoreMetadata

Direct Known Subclasses:

ParquetStorer

public class StoreFuncMetadataWrapper
extends StoreFuncWrapper
implements StoreMetadata

Convenience class to extend when decorating a class that implements both StoreFunc and StoreMetadata. It's not abstract so that it will fail to compile if new methods get added to either interface.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StoreFuncMetadataWrapper()

Method Summary

Modifier and Type	Method and Description
protected void	setStoreFunc(StoreMetadata storeFunc) The wrapped StoreMetadata object must be set before method calls are made on this object.
void	storeSchema(ResourceSchema resourceSchema, java.lang.String location, org.apache.hadoop.mapreduce.Job job) Store schema of the data being written
void	storeStatistics(ResourceStatistics resourceStatistics, java.lang.String location, org.apache.hadoop.mapreduce.Job job) Store statistics about the data being written.

Methods inherited from class org.apache.pig.StoreFuncWrapper

checkSchema, cleanupOnFailure, cleanupOnSuccess, getMethodName, getOutputFormat, prepareToWrite, putNext, relToAbsPathForStoreLocation, setStoreFunc, setStoreFuncUDFContextSignature, setStoreLocation

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pig.StoreFuncInterface

addCredentials, supportsParallelWriteToStoreLocation

Constructor Detail

StoreFuncMetadataWrapper

protected StoreFuncMetadataWrapper()

Method Detail

setStoreFunc

protected void setStoreFunc(StoreMetadata storeFunc)

The wrapped StoreMetadata object must be set before method calls are made on this object. Typically, this is done with via constructor, but often times the wrapped object can not be properly initialized until later in the lifecycle of the wrapper object.

Parameters:

storeFunc -

storeStatistics

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

Description copied from interface: StoreMetadata

Store statistics about the data being written.

Specified by:

storeStatistics in interface StoreMetadata

Parameters:

resourceStatistics - statistics to be recorded

location - Location as returned by LoadFunc.relativeToAbsolutePath(String, org.apache.hadoop.fs.Path)

job - The Job object - this should be used only to obtain cluster properties through JobContextImpl.getConfiguration() and not to set/query any runtime job information.

Throws:

java.io.IOException

storeSchema

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

Description copied from interface: StoreMetadata

Store schema of the data being written

Specified by:

storeSchema in interface StoreMetadata

Parameters:

resourceSchema - Schema to be recorded

location - Location as returned by LoadFunc.relativeToAbsolutePath(String, org.apache.hadoop.fs.Path)

job - The Job object - this should be used only to obtain cluster properties through JobContextImpl.getConfiguration() and not to set/query any runtime job information.

Throws:

java.io.IOException