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

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

Enclosing class:

Fetcher

public static class Fetcher.FetcherBuilder
extends Object

Builder for the construction of Fetchers

Constructor Summary

Fetcher.FetcherBuilder(FetcherCallback fetcherCallback, FetchedInputAllocator inputManager, org.apache.hadoop.yarn.api.records.ApplicationId appId, SecretKey shuffleSecret, org.apache.hadoop.conf.Configuration conf)

Method Summary

Fetcher.FetcherBuilder	assignWork(String host, int port, int partition, List<InputAttemptIdentifier> inputs)
Fetcher	build()
Fetcher.FetcherBuilder	setCompressionParameters(org.apache.hadoop.io.compress.CompressionCodec codec)
Fetcher.FetcherBuilder	setConnectionParameters(int connectionTimeout, int readTimeout)
Fetcher.FetcherBuilder	setIFileParams(boolean readAhead, int readAheadBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

Fetcher.FetcherBuilder

public Fetcher.FetcherBuilder(FetcherCallback fetcherCallback,
                              FetchedInputAllocator inputManager,
                              org.apache.hadoop.yarn.api.records.ApplicationId appId,
                              SecretKey shuffleSecret,
                              org.apache.hadoop.conf.Configuration conf)

Method Detail

setCompressionParameters

public Fetcher.FetcherBuilder setCompressionParameters(org.apache.hadoop.io.compress.CompressionCodec codec)

setConnectionParameters

public Fetcher.FetcherBuilder setConnectionParameters(int connectionTimeout,
                                                      int readTimeout)

setIFileParams

public Fetcher.FetcherBuilder setIFileParams(boolean readAhead,
                                             int readAheadBytes)

assignWork

public Fetcher.FetcherBuilder assignWork(String host,
                                         int port,
                                         int partition,
                                         List<InputAttemptIdentifier> inputs)

build

public Fetcher build()