org.apache.hcatalog.mapreduce

Class MultiOutputFormat.MultiOutputCommitter

java.lang.Object

OutputCommitter

org.apache.hcatalog.mapreduce.MultiOutputFormat.MultiOutputCommitter

Enclosing class:

MultiOutputFormat

public class MultiOutputFormat.MultiOutputCommitter
extends OutputCommitter

Constructor Summary

Constructors

Constructor and Description
MultiOutputCommitter(TaskAttemptContext context)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiOutputCommitter

public MultiOutputCommitter(TaskAttemptContext context)
                     throws java.io.IOException,
                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

Method Detail

setupJob

public void setupJob(JobContext jobContext)
              throws java.io.IOException

Throws:

java.io.IOException

setupTask

public void setupTask(TaskAttemptContext taskContext)
               throws java.io.IOException

Throws:

java.io.IOException

needsTaskCommit

public boolean needsTaskCommit(TaskAttemptContext taskContext)
                        throws java.io.IOException

Throws:

java.io.IOException

commitTask

public void commitTask(TaskAttemptContext taskContext)
                throws java.io.IOException

Throws:

java.io.IOException

abortTask

public void abortTask(TaskAttemptContext taskContext)
               throws java.io.IOException

Throws:

java.io.IOException

commitJob

public void commitJob(JobContext jobContext)
               throws java.io.IOException

Throws:

java.io.IOException

abortJob

public void abortJob(JobContext jobContext,
                     State state)
              throws java.io.IOException

Throws:

java.io.IOException