org.apache.tez.runtime.library.shuffle.common
Interface FetcherCallback

All Known Implementing Classes:

ShuffleManager

public interface FetcherCallback

Method Summary

void	fetchFailed(String host, InputAttemptIdentifier srcAttemptIdentifier, boolean connectFailed)
void	fetchSucceeded(String host, InputAttemptIdentifier srcAttemptIdentifier, FetchedInput fetchedInput, long fetchedBytes, long decompressedLength, long copyDuration)

Method Detail

fetchSucceeded

void fetchSucceeded(String host,
                    InputAttemptIdentifier srcAttemptIdentifier,
                    FetchedInput fetchedInput,
                    long fetchedBytes,
                    long decompressedLength,
                    long copyDuration)
                    throws IOException

Throws:

IOException

fetchFailed

void fetchFailed(String host,
                 InputAttemptIdentifier srcAttemptIdentifier,
                 boolean connectFailed)