org.apache.pig.backend.hadoop.executionengine.tez.runtime

Class PigOutputFormatTez.PigOutputCommitterTez

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter

org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigOutputFormatTez.PigOutputCommitterTez

Enclosing class:

PigOutputFormatTez

public static class PigOutputFormatTez.PigOutputCommitterTez
extends PigOutputCommitter

Constructor Summary

Constructors

Constructor and Description
PigOutputFormatTez.PigOutputCommitterTez(org.apache.hadoop.mapreduce.TaskAttemptContext context, java.util.List<POStore> mapStores, java.util.List<POStore> reduceStores)

Method Summary

Methods

Modifier and Type	Method and Description
void	abortJob(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.mapreduce.JobStatus.State state)
void	commitJob(org.apache.hadoop.mapreduce.JobContext context)
void	setupJob(org.apache.hadoop.mapreduce.JobContext context)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter

abortTask, cleanupJob, commitTask, isRecoverySupported, needsTaskCommit, recoverTask, setUpContext, setupTask, storeCleanup

Methods inherited from class java.lang.Object

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

Constructor Detail

PigOutputFormatTez.PigOutputCommitterTez

public PigOutputFormatTez.PigOutputCommitterTez(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                                        java.util.List<POStore> mapStores,
                                        java.util.List<POStore> reduceStores)
                                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setupJob

public void setupJob(org.apache.hadoop.mapreduce.JobContext context)
              throws java.io.IOException

Overrides:

setupJob in class PigOutputCommitter

Throws:

java.io.IOException

commitJob

public void commitJob(org.apache.hadoop.mapreduce.JobContext context)
               throws java.io.IOException

Overrides:

commitJob in class PigOutputCommitter

Throws:

java.io.IOException

abortJob

public void abortJob(org.apache.hadoop.mapreduce.JobContext context,
            org.apache.hadoop.mapreduce.JobStatus.State state)
              throws java.io.IOException

Overrides:

abortJob in class PigOutputCommitter

Throws:

java.io.IOException