public class MultiOutputFormat.MultiOutputCommitter
extends OutputCommitter
Constructor and Description |
---|
MultiOutputCommitter(TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
abortJob(JobContext jobContext,
State state) |
void |
abortTask(TaskAttemptContext taskContext) |
void |
commitJob(JobContext jobContext) |
void |
commitTask(TaskAttemptContext taskContext) |
boolean |
needsTaskCommit(TaskAttemptContext taskContext) |
void |
setupJob(JobContext jobContext) |
void |
setupTask(TaskAttemptContext taskContext) |
public MultiOutputCommitter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void setupJob(JobContext jobContext) throws java.io.IOException
java.io.IOException
public void setupTask(TaskAttemptContext taskContext) throws java.io.IOException
java.io.IOException
public boolean needsTaskCommit(TaskAttemptContext taskContext) throws java.io.IOException
java.io.IOException
public void commitTask(TaskAttemptContext taskContext) throws java.io.IOException
java.io.IOException
public void abortTask(TaskAttemptContext taskContext) throws java.io.IOException
java.io.IOException
public void commitJob(JobContext jobContext) throws java.io.IOException
java.io.IOException
public void abortJob(JobContext jobContext, State state) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation