MCPcopy Create free account
hub / github.com/apache/pig / cleanupOnFailure

Method cleanupOnFailure

src/org/apache/pig/StoreFuncInterface.java:141–141  ·  view source on GitHub ↗

This method will be called by Pig if the job which contains this store fails. Implementations can clean up output locations in this method to ensure that no incorrect/incomplete results are left in the output location @param location Location returned by {@link StoreFuncInterface#relToAbsPathForStor

(String location, Job job)

Source from the content-addressed store, hash-verified

139 * any runtime job information.
140 */
141 void cleanupOnFailure(String location, Job job) throws IOException;
142
143 /**
144 * This method will be called by Pig if the job which contains this store

Callers 8

testSucessMethod · 0.65
cleanupOnFailureMethod · 0.65
testSucessMethod · 0.65
cleanupOnFailureMethod · 0.65
cleanupOnFailureMethod · 0.65
cleanUpSparkJobMethod · 0.65
launchPigMethod · 0.65
launchPigMethod · 0.65

Implementers 15

AvroStoragecontrib/piggybank/java/src/main/java/o
DummyStoreFunctest/org/apache/pig/TestStoreFuncWrapp
StoreFuncsrc/org/apache/pig/StoreFunc.java
StoreFuncWrappersrc/org/apache/pig/StoreFuncWrapper.ja
AbstractAccumuloStoragesrc/org/apache/pig/backend/hadoop/accu
HBaseStoragesrc/org/apache/pig/backend/hadoop/hbas
InterStoragesrc/org/apache/pig/impl/io/InterStorag
TFileStoragesrc/org/apache/pig/impl/io/TFileStorag
SequenceFileInterStoragesrc/org/apache/pig/impl/io/SequenceFil
OrcStoragesrc/org/apache/pig/builtin/OrcStorage.
PigStoragesrc/org/apache/pig/builtin/PigStorage.
AvroStoragesrc/org/apache/pig/builtin/AvroStorage

Calls

no outgoing calls

Tested by 4

testSucessMethod · 0.52
cleanupOnFailureMethod · 0.52
testSucessMethod · 0.52
cleanupOnFailureMethod · 0.52