org.apache.tez.runtime.library.common

Class TezRuntimeUtils

java.lang.Object

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

@InterfaceAudience.Private
public class TezRuntimeUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
TezRuntimeUtils()

Method Summary

Methods

Modifier and Type	Method and Description
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.TaskContext taskContext)
static Partitioner	instantiatePartitioner(org.apache.hadoop.conf.Configuration conf)
static TezTaskOutput	instantiateTaskOutputManager(org.apache.hadoop.conf.Configuration conf, org.apache.tez.runtime.api.OutputContext 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.TaskContext 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.OutputContext outputContext)