org.apache.tez.runtime.library.common
Class TezRuntimeUtils

java.lang.Object
  org.apache.tez.runtime.library.common.TezRuntimeUtils

public class TezRuntimeUtils
extends Object

Constructor Summary

TezRuntimeUtils()

Method Summary

static String	getTaskAttemptIdentifier(int taskIndex, int taskAttemptNumber)
static String	getTaskAttemptIdentifier(String vertexName, int taskIndex, int taskAttemptNumber)
static String	getTaskIdentifier(String vertexName, int taskIndex)
static Combiner	instantiateCombiner(org.apache.hadoop.conf.Configuration conf, org.apache.tez.runtime.api.TezTaskContext taskContext)
static Partitioner	instantiatePartitioner(org.apache.hadoop.conf.Configuration conf)
static TezTaskOutput	instantiateTaskOutputManager(org.apache.hadoop.conf.Configuration conf, org.apache.tez.runtime.api.TezOutputContext outputContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

TezRuntimeUtils

public TezRuntimeUtils()

Method Detail

getTaskIdentifier

public static String getTaskIdentifier(String vertexName,
                                       int taskIndex)

getTaskAttemptIdentifier

public static String getTaskAttemptIdentifier(int taskIndex,
                                              int taskAttemptNumber)

getTaskAttemptIdentifier

public static String getTaskAttemptIdentifier(String vertexName,
                                              int taskIndex,
                                              int taskAttemptNumber)

instantiateCombiner

public static Combiner instantiateCombiner(org.apache.hadoop.conf.Configuration conf,
                                           org.apache.tez.runtime.api.TezTaskContext taskContext)
                                    throws IOException

Throws:

IOException

instantiatePartitioner

public static Partitioner instantiatePartitioner(org.apache.hadoop.conf.Configuration conf)
                                          throws IOException

Throws:

IOException

instantiateTaskOutputManager

public static TezTaskOutput instantiateTaskOutputManager(org.apache.hadoop.conf.Configuration conf,
                                                         org.apache.tez.runtime.api.TezOutputContext outputContext)