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

java.lang.Object
  extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStoreImpl
Direct Known Subclasses:
FetchPOStoreImpl, MapReducePOStoreImpl

public abstract class POStoreImpl
extends Object

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


Constructor Summary
POStoreImpl()
           
 
Method Summary
 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 IOException
Set up the storer

Parameters:
store - - the POStore object
Throws:
IOException

tearDown

public void tearDown()
              throws IOException
At the end of processing, the outputstream is closed using this method

Throws:
IOException

cleanUp

public void cleanUp()
             throws 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:
IOException


Copyright © 2007-2012 The Apache Software Foundation