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

java.lang.Object
  org.apache.tez.runtime.library.shuffle.common.Fetcher

All Implemented Interfaces:

Callable<FetchResult>

public class Fetcher
extends Object
implements Callable<FetchResult>

Responsible for fetching inputs served by the ShuffleHandler for a single host. Construct using Fetcher.FetcherBuilder

Nested Class Summary

static class

Fetcher.FetcherBuilder Builder for the construction of Fetchers

Method Summary

FetchResult	call()
boolean	equals(Object obj)
int	hashCode()
protected HttpURLConnection	openConnection(URL url)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Detail

call

public FetchResult call()
                 throws Exception

Specified by:

call in interface Callable<FetchResult>

Throws:

Exception

openConnection

protected HttpURLConnection openConnection(URL url)
                                    throws IOException

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object