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

Class ShuffleInputEventHandlerImpl

java.lang.Object

org.apache.tez.runtime.library.common.shuffle.impl.ShuffleInputEventHandlerImpl

All Implemented Interfaces:

ShuffleEventHandler

public class ShuffleInputEventHandlerImpl
extends Object
implements ShuffleEventHandler

A base class for generic Event handling for Inputs which need to Shuffle data.

Constructor Summary

Constructors

Constructor and Description
ShuffleInputEventHandlerImpl(org.apache.tez.runtime.api.InputContext inputContext, ShuffleManager shuffleManager, FetchedInputAllocator inputAllocator, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength)

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

ShuffleInputEventHandlerImpl

public ShuffleInputEventHandlerImpl(org.apache.tez.runtime.api.InputContext inputContext,
                            ShuffleManager shuffleManager,
                            FetchedInputAllocator inputAllocator,
                            org.apache.hadoop.io.compress.CompressionCodec codec,
                            boolean ifileReadAhead,
                            int ifileReadAheadLength)

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