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

java.lang.Object
  org.apache.hadoop.hive.ql.exec.tez.CustomPartitionVertex

All Implemented Interfaces:

org.apache.tez.dag.api.VertexManagerPlugin

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

Constructor Summary

CustomPartitionVertex()

Method Summary

void	initialize(org.apache.tez.dag.api.VertexManagerPluginContext context)
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 java.lang.Object

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

Constructor Detail

CustomPartitionVertex

public CustomPartitionVertex()

Method Detail

initialize

public void initialize(org.apache.tez.dag.api.VertexManagerPluginContext context)

Specified by:

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

onVertexStarted

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

Specified by:

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

onSourceTaskCompleted

public void onSourceTaskCompleted(String srcVertexName,
                                  Integer attemptId)

Specified by:

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

onVertexManagerEventReceived

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

Specified by:

onVertexManagerEventReceived in interface 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 interface org.apache.tez.dag.api.VertexManagerPlugin