org.apache.tez.mapreduce.common

Class MRInputSplitDistributor

java.lang.Object

org.apache.tez.runtime.api.InputInitializer

org.apache.tez.mapreduce.common.MRInputSplitDistributor

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class MRInputSplitDistributor
extends org.apache.tez.runtime.api.InputInitializer

Implements an InputInitializer that distributes Map Reduce splits created by the client to tasks in the Vertex This can be used when certain reasons (e.g. security) prevent splits from being produced in the App Master via MRInputAMSplitGenerator and splits must be produced at the client. They can still be distributed intelligently among tasks at runtime using this.

Constructor Summary

Constructors

Constructor and Description
MRInputSplitDistributor(org.apache.tez.runtime.api.InputInitializerContext initializerContext)

Method Summary

Modifier and Type	Method and Description
void	handleInputInitializerEvent(List<org.apache.tez.runtime.api.events.InputInitializerEvent> events)
List<org.apache.tez.runtime.api.Event>	initialize()

Methods inherited from class org.apache.tez.runtime.api.InputInitializer

getContext, onVertexStateUpdated

Methods inherited from class java.lang.Object

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

Constructor Detail

MRInputSplitDistributor

public MRInputSplitDistributor(org.apache.tez.runtime.api.InputInitializerContext initializerContext)

Method Detail

initialize

public List<org.apache.tez.runtime.api.Event> initialize()
                                                  throws IOException

Specified by:

initialize in class org.apache.tez.runtime.api.InputInitializer

Throws:

IOException

handleInputInitializerEvent

public void handleInputInitializerEvent(List<org.apache.tez.runtime.api.events.InputInitializerEvent> events)
                                 throws Exception

Specified by:

handleInputInitializerEvent in class org.apache.tez.runtime.api.InputInitializer

Throws:

Exception