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)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
static void	resetUDFContextForThreadReuse()

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

checkOutputSpecs, 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

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
                                                                                                        throws IOException,
                                                                                                               InterruptedException

Overrides:

getRecordWriter in class PigOutputFormat

Throws:

IOException

InterruptedException

getOutputCommitter

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

Overrides:

getOutputCommitter in class PigOutputFormat

Throws:

IOException

InterruptedException

resetUDFContextForThreadReuse

public static void resetUDFContextForThreadReuse()