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

Packages that use FetchedInput

Package	Description
org.apache.tez.runtime.library.common.readers
org.apache.tez.runtime.library.common.shuffle	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.tez.runtime.library.common.shuffle.impl	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

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

Modifier and Type	Method and Description
IFile.Reader	UnorderedKVReader.openIFileReader(FetchedInput fetchedInput)

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

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

Modifier and Type	Class and Description
class	DiskFetchedInput
class	LocalDiskFetchedInput
class	MemoryFetchedInput

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

Modifier and Type	Method and Description
FetchedInput	FetchedInputAllocator.allocate(long actualSize, long compresedSize, InputAttemptIdentifier inputAttemptIdentifier)
FetchedInput	FetchedInputAllocator.allocateType(FetchedInput.Type type, long actualSize, long compresedSize, InputAttemptIdentifier inputAttemptIdentifier)

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

Modifier and Type	Method and Description
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.common.shuffle.impl

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

Modifier and Type	Method and Description
FetchedInput	SimpleFetchedInputAllocator.allocate(long actualSize, long compressedSize, InputAttemptIdentifier inputAttemptIdentifier)
FetchedInput	SimpleFetchedInputAllocator.allocateType(FetchedInput.Type type, long actualSize, long compressedSize, InputAttemptIdentifier inputAttemptIdentifier)
FetchedInput	ShuffleManager.getNextInput()

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

Modifier and Type	Method and Description
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)