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
PigOutputCommitterTez(org.apache.hadoop.mapreduce.TaskAttemptContext context, List<POStore> mapStores, List<POStore> reduceStores)

Method Summary

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 org.apache.hadoop.mapreduce.OutputCommitter

isCommitJobRepeatable, isRecoverySupported

Methods inherited from class java.lang.Object

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

Constructor Detail

PigOutputCommitterTez

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

Throws:

IOException

Method Detail

setupJob

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

Overrides:

setupJob in class PigOutputCommitter

Throws:

IOException

commitJob

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

Overrides:

commitJob in class PigOutputCommitter

Throws:

IOException

abortJob

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

Overrides:

abortJob in class PigOutputCommitter

Throws:

IOException