@InterfaceAudience.Public @InterfaceStability.Evolving public interface PartialOutputCommitter
OutputCommitterimplementing partial commit of task output, as during preemption.
|Modifier and Type||Method and Description|
Remove all previously committed outputs from prior executions of this task.
void cleanUpPartialOutputForTask(TaskAttemptContext context) throws IOException
context- Context for cleaning up previously promoted output.
IOException- If cleanup fails, then the state of the task my not be well defined.
Copyright © 2022 Apache Software Foundation. All rights reserved.