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

Class TezJobSplitWriter

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.tez.util.TezJobSplitWriter

public class TezJobSplitWriter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TezJobSplitWriter()

Method Summary

Modifier and Type	Method and Description
static void	createSplitFiles(org.apache.hadoop.fs.Path jobSubmitDir, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.mapreduce.InputSplit[] splits, org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto splitsProto) Create split files and write splits as well as as splits metadata

Methods inherited from class java.lang.Object

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

Constructor Detail

TezJobSplitWriter

public TezJobSplitWriter()

Method Detail

createSplitFiles

public static void createSplitFiles(org.apache.hadoop.fs.Path jobSubmitDir,
                                    org.apache.hadoop.conf.Configuration conf,
                                    org.apache.hadoop.fs.FileSystem fs,
                                    org.apache.hadoop.mapreduce.InputSplit[] splits,
                                    org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto splitsProto)
                             throws java.io.IOException,
                                    java.lang.InterruptedException

Create split files and write splits as well as as splits metadata

Parameters:

jobSubmitDir -

conf -

fs -

splits -

splitsProto -

Throws:

java.io.IOException

java.lang.InterruptedException