public class CustomPartitionVertex
extends org.apache.tez.dag.api.VertexManagerPlugin
Modifier and Type | Class and Description |
---|---|
class |
CustomPartitionVertex.PathComparatorForSplit |
Constructor and Description |
---|
CustomPartitionVertex(org.apache.tez.dag.api.VertexManagerPluginContext context) |
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) |
public CustomPartitionVertex(org.apache.tez.dag.api.VertexManagerPluginContext context)
public void initialize()
initialize
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onVertexStarted(Map<String,List<Integer>> completions)
onVertexStarted
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onSourceTaskCompleted(String srcVertexName, Integer attemptId)
onSourceTaskCompleted
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)
onVertexManagerEventReceived
in class org.apache.tez.dag.api.VertexManagerPlugin
Copyright © 2016 The Apache Software Foundation. All rights reserved.