public class ShuffleInputEventHandlerImpl extends Object implements ShuffleEventHandler
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) |
public ShuffleInputEventHandlerImpl(org.apache.tez.runtime.api.InputContext inputContext, ShuffleManager shuffleManager, FetchedInputAllocator inputAllocator, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength)
public void handleEvents(List<org.apache.tez.runtime.api.Event> events) throws IOException
handleEvents
in interface ShuffleEventHandler
IOException
Copyright © 2015 Apache Software Foundation. All rights reserved.