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

Class PigOutputFormatTez

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.WritableComparable,Tuple>

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

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

public class PigOutputFormatTez
extends PigOutputFormat

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PigOutputFormatTez.PigOutputCommitterTez

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat

PigOutputFormat.PigRecordWriter

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat

currentConf, mapStores, PIG_MAPRED_OUTPUT_DIR, PIG_TMP_PATH, reduceStores

Constructor Summary

Constructors

Constructor and Description
PigOutputFormatTez()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)

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

checkOutputSpecs, getRecordWriter, setLocation, setupUdfEnvAndStores

Methods inherited from class java.lang.Object

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

Constructor Detail

PigOutputFormatTez

public PigOutputFormatTez()

Method Detail

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
                                                               throws java.io.IOException,
                                                                      java.lang.InterruptedException

Overrides:

getOutputCommitter in class PigOutputFormat

Throws:

java.io.IOException

java.lang.InterruptedException