org.apache.hadoop.hive.ql.exec.tez

Class CustomPartitionVertex

java.lang.Object

org.apache.tez.dag.api.VertexManagerPlugin

org.apache.hadoop.hive.ql.exec.tez.CustomPartitionVertex

public class CustomPartitionVertex
extends org.apache.tez.dag.api.VertexManagerPlugin

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CustomPartitionVertex.PathComparatorForSplit

Constructor Summary

Constructors

Constructor and Description
CustomPartitionVertex(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize()
void	onRootVertexInitialized(String inputName, org.apache.tez.dag.api.InputDescriptor inputDescriptor, List<org.apache.tez.runtime.api.Event> events)
void	onSourceTaskCompleted(String srcVertexName, Integer attemptId)
void	onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)
void	onVertexStarted(Map<String,List<Integer>> completions)

Methods inherited from class org.apache.tez.dag.api.VertexManagerPlugin

getContext, onVertexStateUpdated

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomPartitionVertex

public CustomPartitionVertex(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Detail

initialize

public void initialize()

Specified by:

initialize in class org.apache.tez.dag.api.VertexManagerPlugin

onVertexStarted

public void onVertexStarted(Map<String,List<Integer>> completions)

Specified by:

onVertexStarted in class org.apache.tez.dag.api.VertexManagerPlugin

onSourceTaskCompleted

public void onSourceTaskCompleted(String srcVertexName,
                         Integer attemptId)

Specified by:

onSourceTaskCompleted in class org.apache.tez.dag.api.VertexManagerPlugin

onVertexManagerEventReceived

public void onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)

Specified by:

onVertexManagerEventReceived in class org.apache.tez.dag.api.VertexManagerPlugin

onRootVertexInitialized

public void onRootVertexInitialized(String inputName,
                           org.apache.tez.dag.api.InputDescriptor inputDescriptor,
                           List<org.apache.tez.runtime.api.Event> events)

Specified by:

onRootVertexInitialized in class org.apache.tez.dag.api.VertexManagerPlugin