|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of InputAttemptIdentifier in org.apache.tez.runtime.library.common.shuffle.impl |
|---|
| Methods in org.apache.tez.runtime.library.common.shuffle.impl with parameters of type InputAttemptIdentifier | |
|---|---|
org.apache.tez.runtime.library.common.shuffle.impl.MapOutput |
MergeManager.reserve(InputAttemptIdentifier srcAttemptIdentifier,
long requestedSize,
int fetcher)
|
| Constructors in org.apache.tez.runtime.library.common.shuffle.impl with parameters of type InputAttemptIdentifier | |
|---|---|
InMemoryReader(MergeManager merger,
InputAttemptIdentifier taskAttemptId,
byte[] data,
int start,
int length)
|
|
| Uses of InputAttemptIdentifier in org.apache.tez.runtime.library.common.task.local.output |
|---|
| Methods in org.apache.tez.runtime.library.common.task.local.output with parameters of type InputAttemptIdentifier | |
|---|---|
org.apache.hadoop.fs.Path |
TezTaskOutputFiles.getInputFile(InputAttemptIdentifier attemptIdentifier)
Return a local reduce input file created earlier |
abstract org.apache.hadoop.fs.Path |
TezTaskOutput.getInputFile(InputAttemptIdentifier attemptIdentifier)
Return a local reduce input file created earlier |
org.apache.hadoop.fs.Path |
TezLocalTaskOutputFiles.getInputFile(InputAttemptIdentifier mapId)
Return a local reduce input file created earlier |
| Uses of InputAttemptIdentifier in org.apache.tez.runtime.library.shuffle.common |
|---|
| Fields in org.apache.tez.runtime.library.shuffle.common declared as InputAttemptIdentifier | |
|---|---|
protected InputAttemptIdentifier |
FetchedInput.inputAttemptIdentifier
|
| Methods in org.apache.tez.runtime.library.shuffle.common that return InputAttemptIdentifier | |
|---|---|
InputAttemptIdentifier |
FetchedInput.getInputAttemptIdentifier()
|
| Methods in org.apache.tez.runtime.library.shuffle.common that return types with arguments of type InputAttemptIdentifier | |
|---|---|
List<InputAttemptIdentifier> |
InputHost.clearAndGetPendingInputs()
|
Iterable<InputAttemptIdentifier> |
FetchResult.getPendingInputs()
|
| Methods in org.apache.tez.runtime.library.shuffle.common with parameters of type InputAttemptIdentifier | |
|---|---|
void |
InputHost.addKnownInput(InputAttemptIdentifier srcAttempt)
|
FetchedInput |
FetchedInputAllocator.allocate(long actualSize,
long compresedSize,
InputAttemptIdentifier inputAttemptIdentifier)
|
void |
FetcherCallback.fetchFailed(String host,
InputAttemptIdentifier srcAttemptIdentifier,
boolean connectFailed)
|
void |
FetcherCallback.fetchSucceeded(String host,
InputAttemptIdentifier srcAttemptIdentifier,
FetchedInput fetchedInput,
long fetchedBytes,
long decompressedLength,
long copyDuration)
|
| Method parameters in org.apache.tez.runtime.library.shuffle.common with type arguments of type InputAttemptIdentifier | |
|---|---|
Fetcher.FetcherBuilder |
Fetcher.FetcherBuilder.assignWork(String host,
int port,
int partition,
List<InputAttemptIdentifier> inputs)
|
| Constructors in org.apache.tez.runtime.library.shuffle.common with parameters of type InputAttemptIdentifier | |
|---|---|
DiskFetchedInput(long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.LocalDirAllocator localDirAllocator,
TezTaskOutputFiles filenameAllocator)
|
|
FetchedInput(FetchedInput.Type type,
long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler)
|
|
MemoryFetchedInput(long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler)
|
|
| Constructor parameters in org.apache.tez.runtime.library.shuffle.common with type arguments of type InputAttemptIdentifier | |
|---|---|
FetchResult(String host,
int port,
int partition,
Iterable<InputAttemptIdentifier> pendingInputs)
|
|
| Uses of InputAttemptIdentifier in org.apache.tez.runtime.library.shuffle.common.impl |
|---|
| Methods in org.apache.tez.runtime.library.shuffle.common.impl with parameters of type InputAttemptIdentifier | |
|---|---|
void |
ShuffleManager.addCompletedInputWithData(InputAttemptIdentifier srcAttemptIdentifier,
FetchedInput fetchedInput)
|
void |
ShuffleManager.addCompletedInputWithNoData(InputAttemptIdentifier srcAttemptIdentifier)
|
void |
ShuffleManager.addKnownInput(String hostName,
int port,
InputAttemptIdentifier srcAttemptIdentifier,
int srcPhysicalIndex)
|
FetchedInput |
SimpleFetchedInputAllocator.allocate(long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier)
|
void |
ShuffleManager.fetchFailed(String host,
InputAttemptIdentifier srcAttemptIdentifier,
boolean connectFailed)
|
void |
ShuffleManager.fetchSucceeded(String host,
InputAttemptIdentifier srcAttemptIdentifier,
FetchedInput fetchedInput,
long fetchedBytes,
long decompressedLength,
long copyDuration)
|
void |
ShuffleManager.obsoleteKnownInput(InputAttemptIdentifier srcAttemptIdentifier)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||