org.apache.pig.backend.hadoop.executionengine.fetch
Class FetchPOStoreImpl

java.lang.Object
  extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStoreImpl
      extended by org.apache.pig.backend.hadoop.executionengine.fetch.FetchPOStoreImpl

public class FetchPOStoreImpl
extends POStoreImpl

This class is used to have a POStore write the output to the underlying storage via a output collector/record writer in case of a fetch task. It sets up dummy context objects which otherwise would be initialized by the Hadoop job itself.


Constructor Summary
FetchPOStoreImpl(PigContext pc)
           
 
Method Summary
 void cleanUp()
          To perform cleanup when there is an error.
 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

FetchPOStoreImpl

public FetchPOStoreImpl(PigContext pc)
Method Detail

createStoreFunc

public StoreFuncInterface createStoreFunc(POStore store)
                                   throws IOException
Description copied from class: POStoreImpl
Set up the storer

Specified by:
createStoreFunc in class POStoreImpl
Parameters:
store - - the POStore object
Throws:
IOException

tearDown

public void tearDown()
              throws IOException
Description copied from class: POStoreImpl
At the end of processing, the outputstream is closed using this method

Overrides:
tearDown in class POStoreImpl
Throws:
IOException

cleanUp

public void cleanUp()
             throws IOException
Description copied from class: POStoreImpl
To perform cleanup when there is an error. Uses the FileLocalizer method which only deletes the file but not the dirs created with it.

Overrides:
cleanUp in class POStoreImpl
Throws:
IOException


Copyright © 2007-2012 The Apache Software Foundation