Dear Wiki user,
You have subscribed to a wiki page or wiki category on "Pig Wiki" for change
The "LoadStoreRedesignProposal" page has been changed by AlanGates:
void prepareToWrite(RecordWriter writer);
- * Called when all writing is finished.
+ * Called when all writing is finished. This will be called on the
+ * once for each writing task.
@@ -330, +331 @@
* @throws IOException
void putNext(Tuple t) throws IOException;
+ * Called when writing all of the data is finished. This can be used
+ * to commit information to a metadata system, clean up tmp files,
+ * close connections, etc. This call will be made on the front end
+ * after all back end processing is finished.
+ void allFinished();
@@ -461, +472 @@
== Changes ==
Sept 23 2009, Gates
* Changed setURI to setLocation in !LoadFunc and !StoreFunc. Also changed
it to throw IOException in the cases where the passed in location is not valid
for this load or store mechanism.
- * Changed LoadSchema to ResourceSchema and LoadStatistics to
+ * Changed !LoadSchema to !ResourceSchema and !LoadStatistics to
- * Added getPartitionKeys and setPartitionFilter to LoadMetadata
+ * Added getPartitionKeys and setPartitionFilter to !LoadMetadata
+ Sept 25 2009, Gates
+ * Added allFinished call to !StoreFunc