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

Interface FetcherCallback

All Known Implementing Classes:

ShuffleManager

public interface FetcherCallback

Method Summary

Methods

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