org.apache.tez.mapreduce.common

Class MRInputAMSplitGenerator

java.lang.Object

org.apache.tez.runtime.api.InputInitializer

org.apache.tez.mapreduce.common.MRInputAMSplitGenerator

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

Implements an InputInitializer that generates Map Reduce splits in the App Master. This may utilizes the up to date cluster information to create an optimal distribution of splits. This is the recommended InputInitializer to use when reading Map Reduce compatible data sources.

Constructor Summary

Constructors

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

Method Summary

Methods

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

MRInputAMSplitGenerator

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

Method Detail

initialize

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

Specified by:

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

Throws:

Exception

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