|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use FetchedInputAllocator | |
|---|---|
| org.apache.tez.runtime.library.shuffle.common | |
| org.apache.tez.runtime.library.shuffle.common.impl | |
| Uses of FetchedInputAllocator in org.apache.tez.runtime.library.shuffle.common |
|---|
| Constructors in org.apache.tez.runtime.library.shuffle.common with parameters of type FetchedInputAllocator | |
|---|---|
Fetcher.FetcherBuilder(FetcherCallback fetcherCallback,
FetchedInputAllocator inputManager,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
SecretKey shuffleSecret,
org.apache.hadoop.conf.Configuration conf)
|
|
| Uses of FetchedInputAllocator in org.apache.tez.runtime.library.shuffle.common.impl |
|---|
| Classes in org.apache.tez.runtime.library.shuffle.common.impl that implement FetchedInputAllocator | |
|---|---|
class |
SimpleFetchedInputAllocator
Usage: Create instance, setInitialMemoryAvailable(long), configureAndStart() |
| Constructors in org.apache.tez.runtime.library.shuffle.common.impl with parameters of type FetchedInputAllocator | |
|---|---|
ShuffleInputEventHandlerImpl(org.apache.tez.runtime.api.TezInputContext inputContext,
ShuffleManager shuffleManager,
FetchedInputAllocator inputAllocator,
org.apache.hadoop.io.compress.CompressionCodec codec,
boolean ifileReadAhead,
int ifileReadAheadLength)
|
|
ShuffleManager(org.apache.tez.runtime.api.TezInputContext inputContext,
org.apache.hadoop.conf.Configuration conf,
int numInputs,
int bufferSize,
boolean ifileReadAheadEnabled,
int ifileReadAheadLength,
org.apache.hadoop.io.compress.CompressionCodec codec,
FetchedInputAllocator inputAllocator)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||