Uses of Interface
org.apache.tez.runtime.library.common.shuffle.FetchedInputAllocator

Packages that use FetchedInputAllocator

Package	Description
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 FetchedInputAllocator in org.apache.tez.runtime.library.common.shuffle

Constructors in org.apache.tez.runtime.library.common.shuffle with parameters of type FetchedInputAllocator

Constructor and Description
Fetcher.FetcherBuilder(FetcherCallback fetcherCallback, HttpConnectionParams params, FetchedInputAllocator inputManager, org.apache.hadoop.yarn.api.records.ApplicationId appId, int dagIdentifier, org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretMgr, String srcNameTrimmed, org.apache.hadoop.conf.Configuration conf, boolean localDiskFetchEnabled, String localHostname, int shufflePort, boolean asyncHttp)
Fetcher.FetcherBuilder(FetcherCallback fetcherCallback, HttpConnectionParams params, FetchedInputAllocator inputManager, org.apache.hadoop.yarn.api.records.ApplicationId appId, int dagIdentifier, org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretMgr, String srcNameTrimmed, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.RawLocalFileSystem localFs, org.apache.hadoop.fs.LocalDirAllocator localDirAllocator, org.apache.hadoop.fs.Path lockPath, boolean localDiskFetchEnabled, boolean sharedFetchEnabled, String localHostname, int shufflePort, boolean asyncHttp)

Uses of FetchedInputAllocator in org.apache.tez.runtime.library.common.shuffle.impl

Classes in org.apache.tez.runtime.library.common.shuffle.impl that implement FetchedInputAllocator

Modifier and Type	Class and Description
class	SimpleFetchedInputAllocator Usage: Create instance, setInitialMemoryAvailable(long), configureAndStart()

Constructors in org.apache.tez.runtime.library.common.shuffle.impl with parameters of type FetchedInputAllocator

Constructor and Description
ShuffleInputEventHandlerImpl(org.apache.tez.runtime.api.InputContext inputContext, ShuffleManager shuffleManager, FetchedInputAllocator inputAllocator, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength)
ShuffleManager(org.apache.tez.runtime.api.InputContext inputContext, org.apache.hadoop.conf.Configuration conf, int numInputs, int bufferSize, boolean ifileReadAheadEnabled, int ifileReadAheadLength, org.apache.hadoop.io.compress.CompressionCodec codec, FetchedInputAllocator inputAllocator)