B C D F G H I J M N O P R S T U W

B

build() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

buildPartial() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

C

clear() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

clearJobToken() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

clearUser() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

clone() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

close() - Method in class org.apache.hadoop.mapred.FadvisedChunkedFile

CONNECTION_CLOSE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

CURRENT_VERSION_INFO - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

D

DEFAULT_MAX_SHUFFLE_CONNECTIONS - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_MAX_SHUFFLE_THREADS - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_BUFFER_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_CONNECTION_KEEP_ALIVE_ENABLED - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_CONNECTION_KEEP_ALIVE_TIME_OUT - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_LISTEN_QUEUE_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_MANAGE_OS_CACHE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_MAPOUTPUT_META_INFO_CACHE_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_MAX_SESSION_OPEN_FILES - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_PORT - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_READAHEAD_BYTES - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SHUFFLE_TRANSFERTO_ALLOWED - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

DEFAULT_SUFFLE_SSL_FILE_BUFFER_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

deserializeMetaData(ByteBuffer) - Static method in class org.apache.hadoop.mapred.ShuffleHandler

A helper function to deserialize the metadata returned by ShuffleHandler.

F

FadvisedChunkedFile - Class in org.apache.hadoop.mapred

FadvisedChunkedFile(RandomAccessFile, long, long, int, boolean, int, ReadaheadPool, String) - Constructor for class org.apache.hadoop.mapred.FadvisedChunkedFile

FadvisedFileRegion - Class in org.apache.hadoop.mapred

FadvisedFileRegion(RandomAccessFile, long, long, boolean, int, ReadaheadPool, String, int, boolean) - Constructor for class org.apache.hadoop.mapred.FadvisedFileRegion

FETCH_RETRY_DELAY - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

G

getCurrentVersion() - Method in class org.apache.hadoop.mapred.ShuffleHandler

getDefaultInstance() - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getDefaultInstanceForType() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

getDefaultInstanceForType() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getDescriptor() - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos

getDescriptor() - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

getDescriptor() - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getDescriptorForType() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

getJobToken() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

getJobToken() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional .hadoop.common.TokenProto jobToken = 2;

getJobToken() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional .hadoop.common.TokenProto jobToken = 2;

getJobTokenBuilder() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

getJobTokenOrBuilder() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

getJobTokenOrBuilder() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional .hadoop.common.TokenProto jobToken = 2;

getJobTokenOrBuilder() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional .hadoop.common.TokenProto jobToken = 2;

getMetaData() - Method in class org.apache.hadoop.mapred.ShuffleHandler

getParserForType() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getSerializedSize() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getShuffle(Configuration) - Method in class org.apache.hadoop.mapred.ShuffleHandler

getUnknownFields() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

getUser() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

getUser() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional string user = 1;

getUser() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional string user = 1;

getUserBytes() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

getUserBytes() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional string user = 1;

getUserBytes() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional string user = 1;

H

hasJobToken() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

hasJobToken() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional .hadoop.common.TokenProto jobToken = 2;

hasJobToken() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional .hadoop.common.TokenProto jobToken = 2;

hasUser() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

hasUser() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

optional string user = 1;

hasUser() - Method in interface org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder

optional string user = 1;

I

initializeApplication(ApplicationInitializationContext) - Method in class org.apache.hadoop.mapred.ShuffleHandler

internalGetFieldAccessorTable() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

internalGetFieldAccessorTable() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

isInitialized() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

isInitialized() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

J

JOBTOKEN_FIELD_NUMBER - Static variable in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

M

MAPREDUCE_SHUFFLE_SERVICEID - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

MAX_SHUFFLE_CONNECTIONS - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

MAX_SHUFFLE_THREADS - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

mergeFrom(Message) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

mergeFrom(ShuffleHandlerRecoveryProtos.JobShuffleInfoProto) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

mergeJobToken(SecurityProtos.TokenProto) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

N

newBuilder() - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

newBuilder(ShuffleHandlerRecoveryProtos.JobShuffleInfoProto) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

newBuilderForType() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

nextChunk() - Method in class org.apache.hadoop.mapred.FadvisedChunkedFile

O

org.apache.hadoop.mapred - package org.apache.hadoop.mapred

org.apache.hadoop.mapred.proto - package org.apache.hadoop.mapred.proto

P

parseDelimitedFrom(InputStream) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(ByteString) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(byte[]) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(InputStream) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(CodedInputStream) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

PARSER - Static variable in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

pipelineFact - Variable in class org.apache.hadoop.mapred.ShuffleHandler

R

registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos

releaseExternalResources() - Method in class org.apache.hadoop.mapred.FadvisedFileRegion

RETRY_AFTER_HEADER - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

S

serializeMetaData(int) - Static method in class org.apache.hadoop.mapred.ShuffleHandler

Serialize the shuffle port into a ByteBuffer for use later on.

serializeServiceData(Token<JobTokenIdentifier>) - Static method in class org.apache.hadoop.mapred.ShuffleHandler

A helper function to serialize the JobTokenIdentifier to be sent to the ShuffleHandler as ServiceData.

serviceInit(Configuration) - Method in class org.apache.hadoop.mapred.ShuffleHandler

serviceStart() - Method in class org.apache.hadoop.mapred.ShuffleHandler

serviceStop() - Method in class org.apache.hadoop.mapred.ShuffleHandler

setJobToken(SecurityProtos.TokenProto) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

setJobToken(SecurityProtos.TokenProto.Builder) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional .hadoop.common.TokenProto jobToken = 2;

setUser(String) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

setUserBytes(ByteString) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder

optional string user = 1;

SHUFFLE_BUFFER_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_CONNECTION_KEEP_ALIVE_ENABLED - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_CONNECTION_KEEP_ALIVE_TIME_OUT - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_LISTEN_QUEUE_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_MANAGE_OS_CACHE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_MAPOUTPUT_META_INFO_CACHE_SIZE - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_MAX_SESSION_OPEN_FILES - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_PORT_CONFIG_KEY - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_READAHEAD_BYTES - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

SHUFFLE_TRANSFERTO_ALLOWED - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

ShuffleHandler - Class in org.apache.hadoop.mapred

ShuffleHandler() - Constructor for class org.apache.hadoop.mapred.ShuffleHandler

ShuffleHandlerRecoveryProtos - Class in org.apache.hadoop.mapred.proto

ShuffleHandlerRecoveryProtos.JobShuffleInfoProto - Class in org.apache.hadoop.mapred.proto

Protobuf type hadoop.mapreduce.JobShuffleInfoProto

ShuffleHandlerRecoveryProtos.JobShuffleInfoProto.Builder - Class in org.apache.hadoop.mapred.proto

Protobuf type hadoop.mapreduce.JobShuffleInfoProto

ShuffleHandlerRecoveryProtos.JobShuffleInfoProtoOrBuilder - Interface in org.apache.hadoop.mapred.proto

stopApplication(ApplicationTerminationContext) - Method in class org.apache.hadoop.mapred.ShuffleHandler

SUFFLE_SSL_FILE_BUFFER_SIZE_KEY - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

T

toBuilder() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

TOO_MANY_REQ_STATUS - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

transferSuccessful() - Method in class org.apache.hadoop.mapred.FadvisedFileRegion

Call when the transfer completes successfully so we can advise the OS that we don't need the region to be cached anymore.

transferTo(WritableByteChannel, long) - Method in class org.apache.hadoop.mapred.FadvisedFileRegion

U

USER_FIELD_NUMBER - Static variable in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

W

WINDOWS_DEFAULT_SHUFFLE_TRANSFERTO_ALLOWED - Static variable in class org.apache.hadoop.mapred.ShuffleHandler

writeReplace() - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

writeTo(CodedOutputStream) - Method in class org.apache.hadoop.mapred.proto.ShuffleHandlerRecoveryProtos.JobShuffleInfoProto

B C D F G H I J M N O P R S T U W