org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Class POStoreImpl

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStoreImpl

Direct Known Subclasses:

FetchPOStoreImpl, MapReducePOStoreImpl

public abstract class POStoreImpl
extends java.lang.Object

This class is used to specify the actual behavior of the store operator just when ready to start execution.

Constructor Summary

Constructors

Constructor and Description
POStoreImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanUp() To perform cleanup when there is an error.
abstract StoreFuncInterface	createStoreFunc(POStore store) Set up the storer
void	tearDown() At the end of processing, the outputstream is closed using this method

Methods inherited from class java.lang.Object

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

Constructor Detail

POStoreImpl

public POStoreImpl()

Method Detail

createStoreFunc

public abstract StoreFuncInterface createStoreFunc(POStore store)
                                            throws java.io.IOException

Set up the storer

Parameters:

store - - the POStore object

Throws:

java.io.IOException

tearDown

public void tearDown()
              throws java.io.IOException

At the end of processing, the outputstream is closed using this method

Throws:

java.io.IOException

cleanUp

public void cleanUp()
             throws java.io.IOException

To perform cleanup when there is an error. Uses the FileLocalizer method which only deletes the file but not the dirs created with it.

Throws:

java.io.IOException