@SuppressWarnings("rawtypes")
private UnorderedKVReader createReader(TezCounter inputRecordCounter, CompressionCodec codec,
int ifileBufferSize, boolean ifileReadAheadEnabled, int ifileReadAheadLength)
throws IOException {
return new UnorderedKVReader(shuffleManager, conf, codec, ifileReadAheadEnabled,
ifileReadAheadLength, ifileBufferSize, inputRecordCounter);
}