Uses of Class
org.apache.tez.runtime.library.shuffle.common.FetchedInput

Packages that use FetchedInput

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

Uses of FetchedInput in org.apache.tez.runtime.library.common.readers

Methods in org.apache.tez.runtime.library.common.readers with parameters of type FetchedInput

IFile.Reader

ShuffledUnorderedKVReader.openIFileReader(FetchedInput fetchedInput)

Uses of FetchedInput in org.apache.tez.runtime.library.shuffle.common

Subclasses of FetchedInput in org.apache.tez.runtime.library.shuffle.common

class	DiskFetchedInput
class	MemoryFetchedInput

Methods in org.apache.tez.runtime.library.shuffle.common that return FetchedInput

FetchedInput

FetchedInputAllocator.allocate(long actualSize, long compresedSize, InputAttemptIdentifier inputAttemptIdentifier)

Methods in org.apache.tez.runtime.library.shuffle.common with parameters of type FetchedInput

void	FetchedInputCallback.fetchComplete(FetchedInput fetchedInput)
void	FetchedInputCallback.fetchFailed(FetchedInput fetchedInput)
void	FetcherCallback.fetchSucceeded(String host, InputAttemptIdentifier srcAttemptIdentifier, FetchedInput fetchedInput, long fetchedBytes, long decompressedLength, long copyDuration)
void	FetchedInputCallback.freeResources(FetchedInput fetchedInput)

Uses of FetchedInput in org.apache.tez.runtime.library.shuffle.common.impl

Methods in org.apache.tez.runtime.library.shuffle.common.impl that return FetchedInput

FetchedInput	SimpleFetchedInputAllocator.allocate(long actualSize, long compressedSize, InputAttemptIdentifier inputAttemptIdentifier)
FetchedInput	ShuffleManager.getNextInput()

Methods in org.apache.tez.runtime.library.shuffle.common.impl with parameters of type FetchedInput

void	ShuffleManager.addCompletedInputWithData(InputAttemptIdentifier srcAttemptIdentifier, FetchedInput fetchedInput)
void	SimpleFetchedInputAllocator.fetchComplete(FetchedInput fetchedInput)
void	SimpleFetchedInputAllocator.fetchFailed(FetchedInput fetchedInput)
void	ShuffleManager.fetchSucceeded(String host, InputAttemptIdentifier srcAttemptIdentifier, FetchedInput fetchedInput, long fetchedBytes, long decompressedLength, long copyDuration)
void	SimpleFetchedInputAllocator.freeResources(FetchedInput fetchedInput)