Class StoreFuncWrapper

src/org/apache/pig/StoreFuncWrapper.java:35–122

Convenience class to extend when decorating a StoreFunc. It's not abstract so that it will fail to compile if new methods get added to StoreFuncInterface. Subclasses must call the setStoreFunc with an instance of StoreFuncInterface before other methods can be called. Not doing so will result in an I

 * result in an IllegalArgumentException when the method is called.
 */
public class StoreFuncWrapper implements StoreFuncInterface {

    private StoreFuncInterface storeFunc;

    protected StoreFuncWrapper() {}

    /**
     * The wrapped StoreFuncInterface 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.
     * @param storeFunc
     */
    protected void setStoreFunc(StoreFuncInterface storeFunc) {
        this.storeFunc = storeFunc;
    }

    @Override
    public String relToAbsPathForStoreLocation(String location, Path path) throws IOException {
        return storeFunc().relToAbsPathForStoreLocation(location, path);
    }

    @Override
    public OutputFormat getOutputFormat() throws IOException {
        return storeFunc().getOutputFormat();
    }

    @Override
    public void setStoreLocation(String location, Job job) throws IOException {
        storeFunc().setStoreLocation(location, job);
    }

    @Override
    public void checkSchema(ResourceSchema resourceSchema) throws IOException {
        storeFunc().checkSchema(resourceSchema);
    }

    @Override
    public void prepareToWrite(RecordWriter recordWriter) throws IOException {
        storeFunc().prepareToWrite(recordWriter);
    }

    @Override
    public void putNext(Tuple tuple) throws IOException {
        storeFunc().putNext(tuple);
    }

    @Override
    public void setStoreFuncUDFContextSignature(String signature) {
        storeFunc().setStoreFuncUDFContextSignature(signature);
    }

    @Override
    public void cleanupOnFailure(String location, Job job) throws IOException {
        storeFunc().cleanupOnFailure(location, job);
    }

    @Override
    public void cleanupOnSuccess(String location, Job job) throws IOException {