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

java.lang.Object
  org.apache.tez.runtime.library.shuffle.common.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

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

Method Summary

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

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.TezInputContext 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