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

Class FetchPOStoreImpl

java.lang.Object

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

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

Constructors

Constructor and Description
FetchPOStoreImpl(PigContext pc)

Method Summary

Methods

Modifier and Type	Method and Description
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 java.io.IOException

Description copied from class: POStoreImpl

Set up the storer

Specified by:

createStoreFunc in class POStoreImpl

Parameters:

store - - the POStore object

Throws:

java.io.IOException

tearDown

public void tearDown()
              throws java.io.IOException

Description copied from class: POStoreImpl

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

Overrides:

tearDown in class POStoreImpl

Throws:

java.io.IOException

cleanUp

public void cleanUp()
             throws java.io.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:

java.io.IOException