@InterfaceAudience.Public
@InterfaceStability.Evolving
public interface PartialOutputCommitter
OutputCommitter
implementing partial commit of task output, as during preemption.Modifier and Type | Method and Description |
---|---|
void |
cleanUpPartialOutputForTask(TaskAttemptContext context)
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 © 2023 Apache Software Foundation. All rights reserved.