public interface OverwritableStoreFunc
StoreFunc
should implement this interface to enable overwriting its
store/output location if it already exists.Modifier and Type | Method and Description |
---|---|
void |
cleanupOutput(POStore store,
org.apache.hadoop.mapreduce.Job job)
This method is called to cleanup the store/output location of this
StoreFunc . |
boolean |
shouldOverwrite()
This method is called by the Pig runtime to determine whether to ignore output validation problems
(see
PigOutputFormat.checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext) and InputOutputFileValidator#validate ) and to delete the existing output. |
boolean shouldOverwrite()
PigOutputFormat.checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext)
and InputOutputFileValidator#validate
) and to delete the existing output.StoreFunc
.void cleanupOutput(POStore store, org.apache.hadoop.mapreduce.Job job) throws IOException
StoreFunc
.store
- The POStore
object to get info about the store
operator for this store function.job
- The Job
object to get job related information.IOException
- if an exception occurs during the cleanup.Copyright © 2007-2017 The Apache Software Foundation