org.apache.hadoop.hive.ql.parse
Class GenTezUtils

java.lang.Object
  org.apache.hadoop.hive.ql.parse.GenTezUtils

public class GenTezUtils
extends Object

GenTezUtils is a collection of shared helper methods to produce TezWork

Method Summary

MapWork	createMapWork(GenTezProcContext context, Operator<?> root, TezWork tezWork, PrunedPartitionList partitions)
ReduceWork	createReduceWork(GenTezProcContext context, Operator<?> root, TezWork tezWork)
UnionWork	createUnionWork(GenTezProcContext context, Operator<?> operator, TezWork tezWork)
static GenTezUtils	getUtils()
void	processFileSink(GenTezProcContext context, FileSinkOperator fileSink)
void	removeUnionOperators(org.apache.hadoop.conf.Configuration conf, GenTezProcContext context, BaseWork work)
void	resetSequenceNumber()

Methods inherited from class java.lang.Object

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

Method Detail

getUtils

public static GenTezUtils getUtils()

resetSequenceNumber

public void resetSequenceNumber()

createUnionWork

public UnionWork createUnionWork(GenTezProcContext context,
                                 Operator<?> operator,
                                 TezWork tezWork)

createReduceWork

public ReduceWork createReduceWork(GenTezProcContext context,
                                   Operator<?> root,
                                   TezWork tezWork)

createMapWork

public MapWork createMapWork(GenTezProcContext context,
                             Operator<?> root,
                             TezWork tezWork,
                             PrunedPartitionList partitions)
                      throws SemanticException

Throws:

SemanticException

removeUnionOperators

public void removeUnionOperators(org.apache.hadoop.conf.Configuration conf,
                                 GenTezProcContext context,
                                 BaseWork work)
                          throws SemanticException

Throws:

SemanticException

processFileSink

public void processFileSink(GenTezProcContext context,
                            FileSinkOperator fileSink)
                     throws SemanticException

Throws:

SemanticException