org.apache.tez.runtime.library.common.shuffle.orderedgrouped

Class ShuffleInputEventHandlerOrderedGrouped

java.lang.Object

org.apache.tez.runtime.library.common.shuffle.orderedgrouped.ShuffleInputEventHandlerOrderedGrouped

All Implemented Interfaces:

ShuffleEventHandler

public class ShuffleInputEventHandlerOrderedGrouped
extends Object
implements ShuffleEventHandler

Constructor Summary

Constructors

Constructor and Description
ShuffleInputEventHandlerOrderedGrouped(org.apache.tez.runtime.api.InputContext inputContext, org.apache.tez.runtime.library.common.shuffle.orderedgrouped.ShuffleScheduler scheduler)

Method Summary

Methods

Modifier and Type	Method and Description
void	handleEvents(List<org.apache.tez.runtime.api.Event> events)
void	logProgress(boolean updateOnClose)

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffleInputEventHandlerOrderedGrouped

public ShuffleInputEventHandlerOrderedGrouped(org.apache.tez.runtime.api.InputContext inputContext,
                                      org.apache.tez.runtime.library.common.shuffle.orderedgrouped.ShuffleScheduler scheduler)

Method Detail

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> events)
                  throws IOException

Specified by:

handleEvents in interface ShuffleEventHandler

Throws:

IOException

logProgress

public void logProgress(boolean updateOnClose)

Specified by:

logProgress in interface ShuffleEventHandler