A B C D E F G H I J K L M N O P Q R S T U V W Y

A

abort() - Method in class org.apache.tez.mapreduce.output.MROutput
MROutput expects that a Processor call abort in case of any error ( including an error during commit ) prior to the Processor's completion
abortOutput(VertexStatus.State) - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
abortTask(TaskAttemptContext) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
addAllSplits(Iterable<? extends MRRuntimeProtos.MRSplitProto>) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addConfigurationForVertex(Configuration, String, Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
addCounter(Counters.Counter) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
addCounter(String, String, long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
addFailedDependency(TezTaskAttemptID) - Method in interface org.apache.tez.common.TezTaskStatus
 
addFailedDependency(TezTaskAttemptID) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
addLog4jSystemProperties(String, List<String>) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Add the JVM system properties necessary to configure ContainerLogAppender.
addMRInput(Vertex, byte[], Class<? extends TezRootInputInitializer>) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Convenience method to add an MR Input to the specified vertex.
addMROutput(Vertex, byte[]) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Convenience method to add an MR Output to the specified vertex.
addMROutputLegacy(Vertex, byte[]) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
addSplit(InputSplit) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
addSplit(InputSplit) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
addSplits(MRRuntimeProtos.MRSplitProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addSplits(int, MRRuntimeProtos.MRSplitProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addSplits(MRRuntimeProtos.MRSplitProto.Builder) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addSplits(int, MRRuntimeProtos.MRSplitProto.Builder) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addSplitsBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
addSplitsBuilder(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
APPLICATION_ATTEMPT_ID - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
APPLICATION_MASTER_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

B

build() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
build() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
build() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
buildPartial() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
buildPartial() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
buildPartial() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 

C

CACHE_ARCHIVES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_ARCHIVES_SIZES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_ARCHIVES_TIMESTAMPS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_ARCHIVES_VISIBILITIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_FILE_TIMESTAMPS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_FILE_VISIBILITIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_FILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_FILES_SIZES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_LOCALARCHIVES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_LOCALFILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CACHE_SYMLINK - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Deprecated. Symlinks are always on and cannot be disabled.
cancelDelegationToken(CancelDelegationTokenRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
cancelDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
CLASSIC_FRAMEWORK_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
CLASSPATH_ARCHIVES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
CLASSPATH_FILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
clear() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
clear() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
clear() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
clearConfigurationBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional bytes configuration_bytes = 1;
clearInputFormatName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
clearSplitBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional bytes split_bytes = 2;
clearSplitClassName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
clearSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
clearSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
clearStatus() - Method in interface org.apache.tez.common.TezTaskStatus
 
clearStatus() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
clearVersion() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
optional int32 version = 1;
ClientCache - Class in org.apache.tez.mapreduce.client
 
ClientCache(Configuration, ResourceMgrDelegate) - Constructor for class org.apache.tez.mapreduce.client.ClientCache
 
ClientServiceDelegate - Class in org.apache.tez.mapreduce.client
 
ClientServiceDelegate(Configuration, ResourceMgrDelegate, JobID) - Constructor for class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
clone() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
clone() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
clone() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
close() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
close(ClientProtocol) - Method in class org.apache.tez.mapreduce.client.YarnTezClientProtocolProvider
 
close() - Method in class org.apache.tez.mapreduce.input.MRInput
 
close() - Method in class org.apache.tez.mapreduce.output.MROutput
 
close() - Method in class org.apache.tez.mapreduce.processor.map.MapProcessor
 
close() - Method in class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 
combine(TezRawKeyValueIterator, IFile.Writer) - Method in class org.apache.tez.mapreduce.combine.MRCombiner
 
COMBINE_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COMBINE_RECORDS_BEFORE_PROGRESS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
commit() - Method in class org.apache.tez.mapreduce.output.MROutput
MROutput expects that a Processor call commit prior to the Processor's completion
commitOutput() - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
commitTask(TaskAttemptContext) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
committer - Variable in class org.apache.tez.mapreduce.output.MROutput
 
committer - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
COMPLETED_MAPS_FOR_REDUCE_SLOWSTART - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
conf - Variable in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
CONFIGURATION_BYTES_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
contentEquals(Counters.Counter) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
Deprecated. 
convertMRToLinearTez(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
Converts a single completely configured MR* job to something that can be understood by the Tez MR runtime.
COUNTER_GROUP_NAME_MAX_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTER_GROUP_NAME_MAX_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTER_GROUPS_MAX_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTER_GROUPS_MAX_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTER_NAME_MAX_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTER_NAME_MAX_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTERS_MAX_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
COUNTERS_MAX_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
create(Configuration) - Method in class org.apache.tez.mapreduce.client.YarnTezClientProtocolProvider
 
create(InetSocketAddress, Configuration) - Method in class org.apache.tez.mapreduce.client.YarnTezClientProtocolProvider
 
createByteStringFromConf(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createConfFromByteString(ByteString) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createConfFromUserPayload(byte[]) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createKey() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
createMockTaskAttemptID(TezTaskContext, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
createMockTaskAttemptIDFromTezTaskAttemptId(TezTaskAttemptID, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
createMockTaskAttemptIDFromTezTaskId(TezTaskID, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
createMRInputPayload(byte[], MRRuntimeProtos.MRSplitsProto) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createMRInputPayload(Configuration, MRRuntimeProtos.MRSplitsProto) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createMRInputPayloadWithGrouping(byte[], String) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Called to specify that grouping of input splits be performed by Tez The configurationBytes conf should have the input format class configuration set to the TezGroupedSplitsInputFormat.
createMRInputPayloadWithGrouping(Configuration, String) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Called to specify that grouping of input splits be performed by Tez The conf should have the input format class configuration set to the TezGroupedSplitsInputFormat.
createNewFormatSplitFromUserPayload(MRRuntimeProtos.MRSplitProto, SerializationFactory) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createOldFormatSplitFromUserPayload(MRRuntimeProtos.MRSplitProto, SerializationFactory) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
createReduceContext(Reducer<INKEY, INVALUE, OUTKEY, OUTVALUE>, Configuration, TaskAttemptID, TezRawKeyValueIterator, Counter, Counter, RecordWriter<OUTKEY, OUTVALUE>, OutputCommitter, StatusReporter, RawComparator<INKEY>, Class<INKEY>, Class<INVALUE>) - Static method in class org.apache.tez.mapreduce.processor.MRTask
 
createSplitProto(T, SerializationFactory) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createSplitProto(InputSplit) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createUserPayloadFromConf(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
createValue() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
credentials - Variable in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 

D

DAG_FILE_PERMISSION - Static variable in class org.apache.tez.mapreduce.client.YARNRunner
 
DAGJobStatus - Class in org.apache.tez.mapreduce.client
 
DAGJobStatus(ApplicationReport, DAGStatus, String) - Constructor for class org.apache.tez.mapreduce.client.DAGJobStatus
 
DEFAULT_JOB_ACL_MODIFY_JOB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_JOB_ACL_VIEW_JOB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_JOB_AM_ACCESS_DISABLED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_LOG_LEVEL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MAP_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MAP_MEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MAPRED_ADMIN_JAVA_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MAPRED_ADMIN_USER_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MAPRED_IFILE_READAHEAD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DEFAULT_MAPRED_IFILE_READAHEAD_BYTES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DEFAULT_MAPREDUCE_APPLICATION_CLASSPATH - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Default CLASSPATH for all YARN MapReduce applications.
DEFAULT_MR_AM_ADMIN_COMMAND_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_COMMAND_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_CONTAINERLAUNCHER_THREAD_COUNT_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_HISTORY_COMPLETE_EVENT_FLUSH_TIMEOUT_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_HISTORY_JOB_COMPLETE_UNFLUSHED_MULTIPLIER - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_HISTORY_MAX_UNFLUSHED_COMPLETE_EVENTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_HISTORY_USE_BATCHED_FLUSH_QUEUE_SIZE_THRESHOLD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_IGNORE_BLACKLISTING_BLACKLISTED_NODE_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_JOB_CLIENT_THREAD_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_JOB_REDUCE_PREEMPTION_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_JOB_REDUCE_RAMP_UP_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_LOG_LEVEL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_MAX_ATTEMPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_NUM_PROGRESS_SPLITS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_SCHEDULER_INTERVAL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_STAGING_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_TASK_ESTIMATOR_SMOOTH_LAMBDA_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_TASK_LISTENER_THREAD_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_TO_RM_WAIT_INTERVAL_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_AM_VMEM_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_CLIENT_MAX_RETRIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_MR_CLIENT_TO_AM_IPC_MAX_RETRIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_REDUCE_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_REDUCE_MEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_SHELL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DEFAULT_SPLIT_METAINFO_MAXSIZE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DELEGATION_KEY_UPDATE_INTERVAL_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DELEGATION_TOKEN_MAX_LIFETIME_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DELEGATION_TOKEN_RENEW_INTERVAL_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
DeprecatedKeys - Class in org.apache.tez.mapreduce.hadoop
 
DeprecatedKeys() - Constructor for class org.apache.tez.mapreduce.hadoop.DeprecatedKeys
 
DeprecatedKeys.MultiStageKeys - Enum in org.apache.tez.mapreduce.hadoop
 
doJobClientMagic(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Sets up parameters which used to be set by the MR JobClient.
done() - Method in class org.apache.tez.mapreduce.processor.MRTask
 

E

equals(Object) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
equals(Object) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
equals(Object) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
equals(Object) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 

F

failTaskAttempt(FailTaskAttemptRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
findCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
findCounter(String, int, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
findCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
FRAMEWORK_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
fromMRJobId(JobID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
fromMRTaskAttemptId(TaskAttemptID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
fromMRTaskId(TaskID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
fromTez(TezCounters) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 

G

generateInputSplits(Configuration, Path) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Helper api to generate splits
generateInputSplitsToMem(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Generates Input splits and stores them in a MRProtos instance.
generateNewSplits(JobContext, String, int) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
generateOldSplits(JobConf, String, int) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
getActiveTrackers() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getActiveTrackers() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getAllJobs() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getAllJobs() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getAndRemoveBasicConfForVertex(Configuration, String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getAndRemoveBasicIntermediateStageConf(Configuration, int) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getAndRemoveBasicNonIntermediateStageConf(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getApplicationId() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getArchiveClassPaths() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the archive entries in classpath as an array of Path
getArchiveTimestamps() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the timestamps of the archives.
getBaseMRConfiguration(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Get default initialize JobConf-based configuration
getBaseMRConfiguration() - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Get default initialize JobConf-based configuration
getBasicConfForVertex(Configuration, String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getBasicIntermediateStageConf(Configuration, int) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getBlacklistedTrackers() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getBlacklistedTrackers() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getCacheArchives() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get cache archives set in the Configuration
getCacheFiles() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get cache files set in the Configuration
getChildQueues(String) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getChildQueues(String) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getCleanupProgress() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getClient(JobID) - Method in class org.apache.tez.mapreduce.client.ClientCache
 
getClusterMetrics() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getClusterMetrics() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getCombinerClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the combiner class for the job.
getCombinerKeyGroupingComparator() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the user defined RawComparator comparator for grouping keys of inputs to the combiner.
getConf() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
getConf() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
getConf() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
getConf() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
getConf() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getConfForVertex(Configuration, String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getConfigUpdates() - Method in class org.apache.tez.mapreduce.input.MRInput
MRInput sets some additional parameters like split location when using the new API.
getConfiguration() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Return the configuration for the job.
getConfigurationBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional bytes configuration_bytes = 1;
getConfigurationBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional bytes configuration_bytes = 1;
getConfigurationBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional bytes configuration_bytes = 1;
getConnectAddress() - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getCounter(Enum<?>) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
getCounter() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
getCounter(Enum<?>) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
getCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
getCounter(Enum<?>) - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
getCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
getCounter(Enum<?>) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
getCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
getCounter(String, String) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
getCounter(Enum<?>) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
getCounters() - Method in interface org.apache.tez.common.TezTaskStatus
 
getCounters(GetCountersRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getCounters() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getCounters() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getCredentials() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get Credentials which may be required to access the splits.
getCredentials() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getCredentials() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getCredentials() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
getCurrentKey() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.MapContextImpl
 
getCurrentKey() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
Get the current key.
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
getCurrentValue() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.MapContextImpl
 
getCurrentValue() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
Get the current value.
getDefaultInstance() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getDefaultInstance() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getDefaultInstance() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
getDefaultInstanceForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getDelegationToken(GetDelegationTokenRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getDelegationToken(Text) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getDelegationToken(Text) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
getDescriptor() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getDescriptorForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
getDescriptorForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
getDescriptorForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
getDiagnosticInfo() - Method in interface org.apache.tez.common.TezTaskStatus
 
getDiagnosticInfo() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getDiagnostics(GetDiagnosticsRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getDisplayName() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
getDisplayName() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
getFailedDependencies() - Method in interface org.apache.tez.common.TezTaskStatus
 
getFailedDependencies() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getFailureInfo() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getFileClassPaths() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the file entries in classpath as an array of Path
getFilesystemName() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getFilesystemName() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getFileTimestamps() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the timestamps of the files.
getFinalReduceVertexName() - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getFinishTime() - Method in interface org.apache.tez.common.TezTaskStatus
 
getFinishTime() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getFinishTime() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getFsStatistics(Path, Configuration) - Static method in class org.apache.tez.mapreduce.common.Utils
Gets a handle to the Statistics instance based on the scheme associated with path.
getFsStatistics(Path, Configuration) - Static method in class org.apache.tez.mapreduce.processor.MRTask
Gets a handle to the Statistics instance based on the scheme associated with path.
getGroup(String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
getGroupedSplits(Configuration, InputSplit[], int, String) - Method in class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper
 
getGroupedSplits(Configuration, List<InputSplit>, int, String) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper
 
getGroupingComparator() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the user defined RawComparator comparator for grouping keys of inputs to the reduce.
getGroupNames() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
getHistoryFile() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getInitialMapVertexName() - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getInputConfOnEdge(Configuration, Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
Given a source and destination vertex, returns the config which should be used for the Input on this edge.
getInputFormatClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the InputFormat class for the job.
getInputFormatName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
getInputFormatName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional string input_format_name = 3;
getInputFormatName() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional string input_format_name = 3;
getInputFormatNameBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
getInputFormatNameBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional string input_format_name = 3;
getInputFormatNameBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional string input_format_name = 3;
getInputSplit() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
getInputSplit() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.MapContextImpl
Get the input split for this map.
getInputSplit() - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
getIntermediateStageConf(Configuration, int) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getIntermediateStageNum(String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getIntermediateStageVertexName(int) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getJar() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the pathname of the job's jar.
getJobACLs() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getJobConf() - Method in class org.apache.tez.mapreduce.hadoop.mapred.JobContextImpl
Get the job Configuration
getJobConf() - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
getJobConf() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
getJobContext() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getJobCounters(JobID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getJobCounters(JobID) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getJobFile() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getJobHistoryDir() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getJobID() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getJobID() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the unique ID for the job.
getJobName() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getJobName() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the user-specified job name.
getJobReport(GetJobReportRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getJobSetupCleanupNeeded() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get whether job-setup and job-cleanup is needed for the job
getJobStatus(JobID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getJobStatus(JobID) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getJobTrackerStatus() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getLength() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
getLength() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
getLocalCacheArchives() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Return the path array of the localized caches
getLocalCacheFiles() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Return the path array of the localized files
getLocalOutputSize() - Method in interface org.apache.tez.common.TezTaskStatus
 
getLocalOutputSize() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getLocations() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
getLocations() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
getLogFileParams(JobID, TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getLogFilePath(JobID, TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getMapFinishTime() - Method in interface org.apache.tez.common.TezTaskStatus
 
getMapFinishTime() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getMapJavaOpts(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Generate JVM options to be used to launch map tasks Uses mapreduce.admin.map.child.java.opts, mapreduce.map.java.opts and mapreduce.map.log.level from config to generate the opts.
getMapOutputKeyClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the key class for the map output data.
getMapOutputValueClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the value class for the map output data.
getMapperClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the Mapper class for the job.
getMapProgress() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getMapResource(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Extract the map task's container resource requirements from the provided configuration.
getMaxMapAttempts() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the configured number of maximum attempts that will be made to run a map task, as specified by the mapred.map.max.attempts property.
getMaxReduceAttempts() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the configured number of maximum attempts that will be made to run a reduce task, as specified by the mapred.reduce.max.attempts property.
getMRAMJavaOpts(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Extract Java Opts for the AM based on MR-based configuration
getMRCounter(TezCounter) - Static method in class org.apache.tez.mapreduce.common.Utils
 
getMRReporter() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getMRToDAGParamMap() - Static method in class org.apache.tez.mapreduce.hadoop.DeprecatedKeys
 
getMRToTezRuntimeParamMap() - Static method in class org.apache.tez.mapreduce.hadoop.DeprecatedKeys
 
getMultiStageParamMap() - Static method in class org.apache.tez.mapreduce.hadoop.DeprecatedKeys
 
getName() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
getName() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
getNeededMem() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getNewFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getNewInputSplit() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy
 
getNewJobID() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getNewJobID() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getNewSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto, Configuration) - Static method in class org.apache.tez.mapreduce.input.MRInput
 
getNumIntermediateStages(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getNumReduceTasks() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get configured the number of reduce tasks for this job.
getNumReservedSlots() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getNumTasks() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the number of splits that were generated.
getNumTasks() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getNumTasks() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getNumUsedSlots() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getOldFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getOldInputSplit() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy
 
getOldRecordReader() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy
 
getOldSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto, Configuration) - Static method in class org.apache.tez.mapreduce.input.MRInput
 
getOutputCommitter() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
 
getOutputCommitter() - Method in class org.apache.tez.mapreduce.output.MROutputLegacy
 
getOutputConfOnEdge(Configuration, Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
Given a source and destination vertex, returns the config which should be used for the Output on this edge.
getOutputFormatClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the OutputFormat class for the job.
getOutputKeyClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the key class for the job output data.
getOutputName() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getOutputValueClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the value class for job outputs.
getParserForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getParserForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getParserForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getPartition(Object, Object, int) - Method in class org.apache.tez.mapreduce.partition.MRPartitioner
 
getPartitionerClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the Partitioner class for the job.
getPhase() - Method in interface org.apache.tez.common.TezTaskStatus
 
getPhase() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getPos() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
getPriority() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getProfileEnabled() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get whether the task profiling is enabled.
getProfileParams() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the profiler configuration arguments.
getProfileTaskRange(boolean) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the range of maps or reduces to profile.
getProgress() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
getProgress() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
return progress based on the amount of data processed so far.
getProgress() - Method in interface org.apache.tez.common.TezTaskStatus
 
getProgress() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
getProgress() - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
getProgress() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
getProgress() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getProgress() - Method in class org.apache.tez.mapreduce.input.MRInput
 
getProgress() - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
getProgressible() - Method in class org.apache.tez.mapreduce.hadoop.mapred.JobContextImpl
Get the progress mechanism for reporting progress.
getProgressible() - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
getProgressible() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
getPropertyNameForIntermediateStage(int, String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getPropertyNameForVertex(String, String) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
getProtocolSignature(String, long, int) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getProtocolVersion(String, long) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getProtocolVersion(String, long) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getQueue() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getQueue(String) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getQueue(String) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getQueueAclsForCurrentUser() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getQueueAclsForCurrentUser() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getQueueAdmins(String) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getQueues() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getQueues() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getRack() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
getRack() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
getReader() - Method in class org.apache.tez.mapreduce.input.MRInput
 
getRecordReader(InputSplit, JobConf, Reporter) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
getReduceJavaOpts(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Generate JVM options to be used to launch reduce tasks Uses mapreduce.admin.reduce.child.java.opts, mapreduce.reduce.java.opts and mapreduce.reduce.log.level from config to generate the opts.
getReduceProgress() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getReducerClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the Reducer class for the job.
getReduceResource(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Extract the reduce task's container resource requirements from the provided configuration.
getReservedMem() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getRootQueues() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getRootQueues() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getRunState() - Method in interface org.apache.tez.common.TezTaskStatus
 
getRunState() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getSchedulingInfo() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getSerializedSize() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getSerializedSize() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getSerializedSize() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getSetupProgress() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getShuffleFinishTime() - Method in interface org.apache.tez.common.TezTaskStatus
 
getShuffleFinishTime() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getSortComparator() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the RawComparator comparator used to compare keys.
getSortFinishTime() - Method in interface org.apache.tez.common.TezTaskStatus
 
getSortFinishTime() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getSplitBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional bytes split_bytes = 2;
getSplitBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
optional bytes split_bytes = 2;
getSplitBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProtoOrBuilder
optional bytes split_bytes = 2;
getSplitClassName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
getSplitClassName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
optional string split_class_name = 1;
getSplitClassName() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProtoOrBuilder
optional string split_class_name = 1;
getSplitClassNameBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
getSplitClassNameBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
optional string split_class_name = 1;
getSplitClassNameBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProtoOrBuilder
optional string split_class_name = 1;
getSplits(JobConf, int) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
getSplits(JobContext) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
getSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
getSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional .MRSplitsProto splits = 2;
getSplits() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional .MRSplitsProto splits = 2;
getSplits(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplits(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
repeated .MRSplitProto splits = 2;
getSplits(int) - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
repeated .MRSplitProto splits = 2;
getSplitsBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
getSplitsBuilder(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsBuilderList() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsCount() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsCount() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
repeated .MRSplitProto splits = 2;
getSplitsCount() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
repeated .MRSplitProto splits = 2;
getSplitsFile() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the path to the splits file
getSplitsFile() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getSplitsFile() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getSplitsList() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsList() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
repeated .MRSplitProto splits = 2;
getSplitsList() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
repeated .MRSplitProto splits = 2;
getSplitsMetaInfoFile() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the path to the splits meta info file
getSplitsMetaInfoFile() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getSplitsMetaInfoFile() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getSplitsOrBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
getSplitsOrBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional .MRSplitsProto splits = 2;
getSplitsOrBuilder() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional .MRSplitsProto splits = 2;
getSplitsOrBuilder(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsOrBuilder(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
repeated .MRSplitProto splits = 2;
getSplitsOrBuilder(int) - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
repeated .MRSplitProto splits = 2;
getSplitsOrBuilderList() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
getSplitsOrBuilderList() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
repeated .MRSplitProto splits = 2;
getSplitsOrBuilderList() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
repeated .MRSplitProto splits = 2;
getSplitsProto() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the splits proto
getSplitsProto() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getSplitsProto() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getStageConfs(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
Given a single base MRR config, returns a list of complete stage configurations.
getStagingAreaDir() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getStagingAreaDir() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getStartTime() - Method in interface org.apache.tez.common.TezTaskStatus
 
getStartTime() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getStartTime() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getState() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getState() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getStateString() - Method in interface org.apache.tez.common.TezTaskStatus
 
getStateString() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getSymlink() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
This method checks to see if symlinks are to be create for the localized cache files in the current working directory
getSystemDir() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getSystemDir() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getTaskAttemptCompletionEvents(GetTaskAttemptCompletionEventsRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getTaskAttemptContext() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getTaskAttemptId() - Method in interface org.apache.tez.common.TezTaskStatus
 
getTaskAttemptID() - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
Get the taskAttemptID.
getTaskAttemptId() - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
getTaskAttemptId() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getTaskAttemptReport(GetTaskAttemptReportRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getTaskCleanupNeeded() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get whether task-cleanup is needed for the job
getTaskCompletionEvents(JobID, int, int) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getTaskCompletionEvents(JobID, int, int) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getTaskDiagnostics(TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getTaskDiagnostics(TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getTaskLocationHints() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the TaskLocationHints for each task
getTaskLocationHints() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getTaskLocationHints() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getTaskReport(GetTaskReportRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getTaskReports(JobID, TaskType) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
getTaskReports(GetTaskReportsRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
getTaskReports(JobID, TaskType) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getTaskTrackerExpiryInterval() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
getTaskTrackerExpiryInterval() - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
getTrackingUrl() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getType() - Method in interface org.apache.tez.mapreduce.hadoop.InputSplitInfo
Get the InputSplitInfo.Type of the InputSplitInfo
getType() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
getType() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
getUmbilical() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
getUnderlyingCounter() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
getUnderlyingGroup() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
getUnknownFields() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
getUnknownFields() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
getUnknownFields() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
getUsedMem() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getUser() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the reported username for this job.
getUsername() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
getValue() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
getVersion() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
optional int32 version = 1;
getVersion() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
optional int32 version = 1;
getVersion() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
optional int32 version = 1;
getWorkingDirectory() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Get the current working directory for the default file system.
getWriter() - Method in class org.apache.tez.mapreduce.output.MROutput
 
GROUP_COMPARATOR_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

H

HADOOP_WORK_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
handleEvents(List<Event>) - Method in class org.apache.tez.mapreduce.input.MRInput
 
handleEvents(List<Event>) - Method in class org.apache.tez.mapreduce.output.MROutput
 
handleEvents(List<Event>) - Method in class org.apache.tez.mapreduce.processor.map.MapProcessor
 
handleEvents(List<Event>) - Method in class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 
hasConfigurationBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional bytes configuration_bytes = 1;
hasConfigurationBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional bytes configuration_bytes = 1;
hasConfigurationBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional bytes configuration_bytes = 1;
hashCode() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
hashCode() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
hashCode() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
hashCode() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
hasInputFormatName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
hasInputFormatName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional string input_format_name = 3;
hasInputFormatName() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional string input_format_name = 3;
hasSplitBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional bytes split_bytes = 2;
hasSplitBytes() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
optional bytes split_bytes = 2;
hasSplitBytes() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProtoOrBuilder
optional bytes split_bytes = 2;
hasSplitClassName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
hasSplitClassName() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
optional string split_class_name = 1;
hasSplitClassName() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProtoOrBuilder
optional string split_class_name = 1;
hasSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
hasSplits() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
optional .MRSplitsProto splits = 2;
hasSplits() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder
optional .MRSplitsProto splits = 2;
hasVersion() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
optional int32 version = 1;
hasVersion() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
optional int32 version = 1;
hasVersion() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProtoOrBuilder
optional int32 version = 1;
holdsNewFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
HS_DELEGATION_TOKEN_REQUIRED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

I

ID - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
IDConverter - Class in org.apache.tez.mapreduce.hadoop
 
IDConverter() - Constructor for class org.apache.tez.mapreduce.hadoop.IDConverter
 
incrAllCounters(Counters) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
incrAllCounters(CounterGroupBase) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
incrCounter(Enum<?>, long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
incrCounter(String, String, long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
incrCounter(Enum<?>, long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
incrCounter(String, String, long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
incrCounter(Enum<?>, long) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
incrCounter(String, String, long) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
increment(long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
INDEX_CACHE_MEMORY_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
init() - Static method in class org.apache.tez.mapreduce.hadoop.DeprecatedKeys
 
init() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy
 
initCommitter(JobConf, boolean) - Method in class org.apache.tez.mapreduce.output.MROutput
 
initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
initialize(OutputCommitterContext) - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
initialize(TezRootInputInitializerContext) - Method in class org.apache.tez.mapreduce.common.MRInputAMSplitGenerator
 
initialize(TezRootInputInitializerContext) - Method in class org.apache.tez.mapreduce.common.MRInputSplitDistributor
 
initialize(TezInputContext) - Method in class org.apache.tez.mapreduce.input.MRInput
 
initialize(TezOutputContext) - Method in class org.apache.tez.mapreduce.output.MROutput
 
initialize(TezProcessorContext) - Method in class org.apache.tez.mapreduce.processor.map.MapProcessor
 
initialize(TezProcessorContext) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
initialize(TezProcessorContext) - Method in class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 
initializeInternal() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy
 
initNextRecordReader() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
initNextRecordReader() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
initTask(LogicalOutput) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
INPUT_FORMAT_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
INPUT_FORMAT_NAME_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
InputSplitInfo - Interface in org.apache.tez.mapreduce.hadoop
Provides information about input splits.
InputSplitInfo.Type - Enum in org.apache.tez.mapreduce.hadoop
 
InputSplitInfoDisk - Class in org.apache.tez.mapreduce.hadoop
Information obtained by using the InputFormat class to generate the required InputSplit information files that in turn can be used to setup a DAG.
InputSplitInfoDisk(Path, Path, int, List<VertexLocationHint.TaskLocationHint>, Credentials) - Constructor for class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk
 
InputSplitInfoMem - Class in org.apache.tez.mapreduce.hadoop
Represents InputSplitInfo for splits generated to memory.
InputSplitInfoMem(InputSplit[], List<VertexLocationHint.TaskLocationHint>, int, Credentials, Configuration) - Constructor for class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
InputSplitInfoMem(InputSplit[], List<VertexLocationHint.TaskLocationHint>, int, Credentials, Configuration) - Constructor for class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
IO_SORT_FACTOR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
IO_SORT_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
IS_MAP_PROCESSOR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
isCommitRequired() - Method in class org.apache.tez.mapreduce.output.MROutput
 
isFinalReduceVertex(String) - Method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
isInitialized() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
isInitialMapVertex(String) - Method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
isJobComplete() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
isRetired() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
isTaskRecoverySupported() - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
isUber() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
iterator() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 

J

JAR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JAR_UNPACK_PATTERN - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_ACL_MODIFY_JOB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_ACL_VIEW_JOB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_AM_ACCESS_DISABLED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
AM ACL disabled.
JOB_CANCEL_DELEGATION_TOKEN - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_CONF_FILE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_JAR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_JOBTRACKER_ID - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_LOCAL_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_NAMENODES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_SPLIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_SPLIT_METAINFO - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_SUBMIT_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_SUBMITHOST - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_SUBMITHOSTADDR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_UBERTASK_ENABLE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_UBERTASK_MAXBYTES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_UBERTASK_MAXMAPS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
JOB_UBERTASK_MAXREDUCES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
jobConf - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
jobContext - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
JobContextImpl - Class in org.apache.tez.mapreduce.hadoop.mapred
 
JobContextImpl(JobConf, TezDAGID, Progressable) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.JobContextImpl
 
JobContextImpl(JobConf, TezDAGID) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.JobContextImpl
 
JobContextImpl - Class in org.apache.tez.mapreduce.hadoop.mapreduce
A read-only view of the job that is provided to the tasks while they are running.
JobContextImpl(Configuration, TezDAGID) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
JobContextImpl(Configuration, TezDAGID, Progressable) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
 
jobTokenSecret - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
JVM_NUMTASKS_TORUN - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

K

KEY_COMPARATOR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
killApplication(ApplicationId) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
killJob(JobID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
killJob(KillJobRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
killJob(JobID) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
killTask(TaskAttemptID, boolean) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate
 
killTask(KillTaskRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
killTask(TaskAttemptID, boolean) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
killTaskAttempt(KillTaskAttemptRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 

L

LOCAL_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
LOCAL_FRAMEWORK_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
localizeConfiguration(JobConf) - Method in class org.apache.tez.mapreduce.processor.map.MapProcessor
 
localizeConfiguration(JobConf) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
localizeConfiguration(JobConf) - Method in class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 
LOG - Static variable in class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez
 
log(Log) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 

M

makeCompactString() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
makeEscapedCompactString() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
makeEscapedCompactString() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
MAP_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_COMBINE_MIN_SPILLS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_DEBUG_SCRIPT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_FAILURES_MAX_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_INPUT_FILE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_INPUT_PATH - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_INPUT_START - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_JAVA_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_LOG_LEVEL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_MAX_ATTEMPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_MEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_MEMORY_PHYSICAL_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_OUTPUT_COMPRESS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_OUTPUT_COMPRESS_CODEC - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_OUTPUT_KEY_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_OUTPUT_KEY_FIELD_SEPERATOR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_OUTPUT_VALUE_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_SKIP_INCR_PROC_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_SKIP_MAX_RECORDS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAP_SORT_SPILL_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MapContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.tez.mapreduce.hadoop.mapreduce
The context that is given to the Mapper.
MapContextImpl(Configuration, TaskAttemptID, RecordReader<KEYIN, VALUEIN>, RecordWriter<KEYOUT, VALUEOUT>, OutputCommitter, TezTaskContext, InputSplit, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.MapContextImpl
 
MAPMEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MapProcessor - Class in org.apache.tez.mapreduce.processor.map
 
MapProcessor() - Constructor for class org.apache.tez.mapreduce.processor.map.MapProcessor
 
MAPRED_ADMIN_USER_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPRED_ADMIN_USER_SHELL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPRED_IFILE_READAHEAD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
Configuration key to enable/disable IFile readahead.
MAPRED_IFILE_READAHEAD_BYTES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
Configuration key to set the IFile readahead length in bytes.
MAPRED_MAP_ADMIN_JAVA_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPRED_REDUCE_ADMIN_JAVA_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPREDUCE_APPLICATION_CLASSPATH - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
CLASSPATH for all YARN MapReduce applications.
MAPREDUCE_JOB_CREDENTIALS_BINARY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPREDUCE_JOB_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPREDUCE_JOB_USER_CLASSPATH_FIRST - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MAPREDUCE_V2_CHILD_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MASTER_ADDRESS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MASTER_USER_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MAX_BLOCK_LOCATIONS_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MAX_BLOCK_LOCATIONS_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MAX_TASK_FAILURES_PER_TRACKER - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
mergeFrom(Message) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
mergeFrom(MRRuntimeProtos.MRInputUserPayloadProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
 
mergeFrom(Message) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
mergeFrom(MRRuntimeProtos.MRSplitProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
 
mergeFrom(Message) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
mergeFrom(MRRuntimeProtos.MRSplitsProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
 
mergeMRBinaryTokens(Credentials, Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Merge tokens from a configured binary file into provided Credentials object.
mergeSplits(MRRuntimeProtos.MRSplitsProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
META_SPLIT_FILE_HEADER - Static variable in class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez
 
META_SPLIT_VERSION - Static variable in class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez
 
MR_ACLS_ENABLED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MR_ADMINS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
MR_AM_ADMIN_COMMAND_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Admin command opts passed to the MR app master.
MR_AM_ADMIN_USER_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_COMMAND_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Command line arguments passed to the MR app master.
MR_AM_CONTAINERLAUNCHER_THREAD_COUNT_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Upper limit on the number of threads user to launch containers in the app master.
MR_AM_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The number of virtual cores the MR app master needs.
MR_AM_CREATE_JH_INTERMEDIATE_BASE_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Boolean.
MR_AM_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_HISTORY_COMPLETE_EVENT_FLUSH_TIMEOUT_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_HISTORY_JOB_COMPLETE_UNFLUSHED_MULTIPLIER - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_HISTORY_MAX_UNFLUSHED_COMPLETE_EVENTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_HISTORY_USE_BATCHED_FLUSH_QUEUE_SIZE_THRESHOLD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_IGNORE_BLACKLISTING_BLACKLISTED_NODE_PERECENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Ignore blacklisting if a certain percentage of nodes have been blacklisted
MR_AM_JOB_CLIENT_PORT_RANGE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Range of ports that the MapReduce AM can use when binding.
MR_AM_JOB_CLIENT_THREAD_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Number of threads to handle job client RPC requests.
MR_AM_JOB_NODE_BLACKLISTING_ENABLE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Enable blacklisting of nodes in the job.
MR_AM_JOB_RECOVERY_ENABLE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Enable job recovery.
MR_AM_JOB_REDUCE_PREEMPTION_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Limit on the number of reducers that can be preempted to ensure that at least one map task can run if it needs to.
MR_AM_JOB_REDUCE_RAMPUP_UP_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Limit reduces starting until a certain percentage of maps have finished.
MR_AM_LOG_LEVEL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Root Logging level passed to the MR app master.
MR_AM_MAX_ATTEMPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_NUM_PROGRESS_SPLITS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The number of splits when reporting progress in MR
MR_AM_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_SCHEDULER_INTERVAL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
How often the AM should schedule assigning tasks with allocated containers.
MR_AM_SECURITY_SERVICE_AUTHORIZATION_CLIENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_SECURITY_SERVICE_AUTHORIZATION_TASK_UMBILICAL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_AM_STAGING_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The staging directory for map reduce.
MR_AM_TASK_ESTIMATOR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
Class used to estimate task resource needs.
MR_AM_TASK_ESTIMATOR_EXPONENTIAL_RATE_ENABLE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
true if the smoothing rate should be exponential.
MR_AM_TASK_ESTIMATOR_SMOOTH_LAMBDA_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The lambda value in the smoothing function of the task estimator.
MR_AM_TASK_LISTENER_THREAD_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The number of threads used to handle task RPC calls.
MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
How often the AM should send heartbeats to the RM.
MR_AM_TO_RM_WAIT_INTERVAL_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
If contact with RM is lost, the AM will wait MR_AM_TO_RM_WAIT_INTERVAL_MS milliseconds before aborting.
MR_AM_VMEM_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The amount of memory the MR app master needs.
MR_CLIENT_MAX_RETRIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The number of client retries to the RM/HS/AM before throwing exception.
MR_CLIENT_TO_AM_IPC_MAX_RETRIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The number of client retires to the AM - before reconnecting to the RM to fetch Application State.
MR_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_SUPERGROUP - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
Deprecated. 
MR_TEZ_INPUT_INITIALIZER_SERIALIZE_EVENT_PAYLAOD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_TEZ_INPUT_INITIALIZER_SERIALIZE_EVENT_PAYLAOD_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_TEZ_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_TEZ_SPLITS_VIA_EVENTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MR_TEZ_SPLITS_VIA_EVENTS_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MRCombiner - Class in org.apache.tez.mapreduce.combine
 
MRCombiner(TezTaskContext) - Constructor for class org.apache.tez.mapreduce.combine.MRCombiner
 
MRConfig - Interface in org.apache.tez.mapreduce.hadoop
Place holder for cluster level configuration keys.
MRCounters - Class in org.apache.tez.mapreduce.hadoop.mapred
 
MRCounters(TezCounters) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
MRCounters.MRCounter - Class in org.apache.tez.mapreduce.hadoop.mapred
 
MRCounters.MRCounter(TezCounter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
MRCounters.MRCounterGroup - Class in org.apache.tez.mapreduce.hadoop.mapred
 
MRCounters.MRCounterGroup(CounterGroup) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
MRHelpers - Class in org.apache.tez.mapreduce.hadoop
 
MRHelpers() - Constructor for class org.apache.tez.mapreduce.hadoop.MRHelpers
 
MRInput - Class in org.apache.tez.mapreduce.input
MRInput is an Input which provides key/values pairs for the consumer.
MRInput() - Constructor for class org.apache.tez.mapreduce.input.MRInput
 
MRInputAMSplitGenerator - Class in org.apache.tez.mapreduce.common
 
MRInputAMSplitGenerator() - Constructor for class org.apache.tez.mapreduce.common.MRInputAMSplitGenerator
 
MRInputLegacy - Class in org.apache.tez.mapreduce.input
 
MRInputLegacy() - Constructor for class org.apache.tez.mapreduce.input.MRInputLegacy
 
MRInputSplitDistributor - Class in org.apache.tez.mapreduce.common
 
MRInputSplitDistributor() - Constructor for class org.apache.tez.mapreduce.common.MRInputSplitDistributor
 
MRJobConfig - Interface in org.apache.tez.mapreduce.hadoop
 
MROutput - Class in org.apache.tez.mapreduce.output
 
MROutput() - Constructor for class org.apache.tez.mapreduce.output.MROutput
 
MROUTPUT_FILE_NAME_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MROutputCommitter - Class in org.apache.tez.mapreduce.committer
 
MROutputCommitter() - Constructor for class org.apache.tez.mapreduce.committer.MROutputCommitter
 
MROutputLegacy - Class in org.apache.tez.mapreduce.output
 
MROutputLegacy() - Constructor for class org.apache.tez.mapreduce.output.MROutputLegacy
 
MRPartitioner - Class in org.apache.tez.mapreduce.partition
 
MRPartitioner(Configuration) - Constructor for class org.apache.tez.mapreduce.partition.MRPartitioner
 
MRR_INTERMEDIATE_STAGE_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MRR_INTERMEDIATE_STAGES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MRR_VERTEX_PREFIX - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
MRReporter - Class in org.apache.tez.mapreduce.hadoop.mapred
 
MRReporter(TezProcessorContext) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
MRReporter(TezTaskContext) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
MRReporter(TezTaskContext, InputSplit) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
mrReporter - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
MRRuntimeProtos - Class in org.apache.tez.mapreduce.protos
 
MRRuntimeProtos.MRInputUserPayloadProto - Class in org.apache.tez.mapreduce.protos
Protobuf type MRInputUserPayloadProto
MRRuntimeProtos.MRInputUserPayloadProto.Builder - Class in org.apache.tez.mapreduce.protos
Protobuf type MRInputUserPayloadProto
MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder - Interface in org.apache.tez.mapreduce.protos
 
MRRuntimeProtos.MRSplitProto - Class in org.apache.tez.mapreduce.protos
Protobuf type MRSplitProto
MRRuntimeProtos.MRSplitProto.Builder - Class in org.apache.tez.mapreduce.protos
Protobuf type MRSplitProto
MRRuntimeProtos.MRSplitProtoOrBuilder - Interface in org.apache.tez.mapreduce.protos
 
MRRuntimeProtos.MRSplitsProto - Class in org.apache.tez.mapreduce.protos
Protobuf type MRSplitsProto
MRRuntimeProtos.MRSplitsProto.Builder - Class in org.apache.tez.mapreduce.protos
Protobuf type MRSplitsProto
MRRuntimeProtos.MRSplitsProtoOrBuilder - Interface in org.apache.tez.mapreduce.protos
 
MRTask - Class in org.apache.tez.mapreduce.processor
 
MRTask(boolean) - Constructor for class org.apache.tez.mapreduce.processor.MRTask
 
MRTaskReporter - Class in org.apache.tez.mapreduce.processor
 
MRTaskReporter(TezProcessorContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter
 
MRTaskReporter(TezOutputContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter
 
MRTaskReporter(TezInputContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter
 
MRTaskStatus - Class in org.apache.tez.mapreduce.hadoop
 
MRTaskStatus() - Constructor for class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
MRTaskStatus(TezTaskAttemptID, TezCounters, TezTaskStatus.Phase) - Constructor for class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
MultiStageMRConfigUtil - Class in org.apache.tez.mapreduce.hadoop
 
MultiStageMRConfigUtil() - Constructor for class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
MultiStageMRConfToTezTranslator - Class in org.apache.tez.mapreduce.hadoop
 
MultiStageMRConfToTezTranslator() - Constructor for class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
 

N

needsTaskCommit(TaskAttemptContext) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
newBuilder() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
newBuilder(MRRuntimeProtos.MRInputUserPayloadProto) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
newBuilder() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
newBuilder(MRRuntimeProtos.MRSplitProto) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
newBuilder() - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
newBuilder(MRRuntimeProtos.MRSplitsProto) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
newBuilderForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
newBuilderForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
newBuilderForType() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
newInputSplit - Variable in class org.apache.tez.mapreduce.input.MRInput
 
next(K, V) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
nextKeyValue() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
nextKeyValue() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.MapContextImpl
 
nextKeyValue() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
Advance to the next key, value pair, returning null if at end.
normalizeStatus(String, Configuration) - Static method in class org.apache.tez.mapreduce.processor.MRTask
 
NotRunningJob - Class in org.apache.tez.mapreduce.client
 
NUM_MAP_PROFILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
NUM_MAPS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
NUM_REDUCE_PROFILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
NUM_REDUCES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

O

oldInputSplit - Variable in class org.apache.tez.mapreduce.input.MRInput
 
oldRecordReader - Variable in class org.apache.tez.mapreduce.input.MRInput
 
org.apache.hadoop.mapred - package org.apache.hadoop.mapred
 
org.apache.hadoop.mapred.split - package org.apache.hadoop.mapred.split
 
org.apache.hadoop.mapreduce.split - package org.apache.hadoop.mapreduce.split
 
org.apache.tez.common - package org.apache.tez.common
 
org.apache.tez.mapreduce.client - package org.apache.tez.mapreduce.client
 
org.apache.tez.mapreduce.combine - package org.apache.tez.mapreduce.combine
 
org.apache.tez.mapreduce.committer - package org.apache.tez.mapreduce.committer
 
org.apache.tez.mapreduce.common - package org.apache.tez.mapreduce.common
 
org.apache.tez.mapreduce.hadoop - package org.apache.tez.mapreduce.hadoop
 
org.apache.tez.mapreduce.hadoop.mapred - package org.apache.tez.mapreduce.hadoop.mapred
 
org.apache.tez.mapreduce.hadoop.mapreduce - package org.apache.tez.mapreduce.hadoop.mapreduce
 
org.apache.tez.mapreduce.input - package org.apache.tez.mapreduce.input
 
org.apache.tez.mapreduce.output - package org.apache.tez.mapreduce.output
 
org.apache.tez.mapreduce.partition - package org.apache.tez.mapreduce.partition
 
org.apache.tez.mapreduce.processor - package org.apache.tez.mapreduce.processor
 
org.apache.tez.mapreduce.processor.map - package org.apache.tez.mapreduce.processor.map
 
org.apache.tez.mapreduce.processor.reduce - package org.apache.tez.mapreduce.processor.reduce
 
org.apache.tez.mapreduce.protos - package org.apache.tez.mapreduce.protos
 
OUTPUT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
OUTPUT_FORMAT_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
OUTPUT_KEY_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
OUTPUT_VALUE_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

P

parseDelimitedFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(ByteString) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(byte[]) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(CodedInputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
parseFrom(ByteString) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(byte[]) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(CodedInputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
parseFrom(ByteString) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(byte[]) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(InputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(CodedInputStream) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
parseMRInputPayload(byte[]) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
 
PARSER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
PARSER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
PARSER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
PARTITIONER_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
PRESERVE_FAILED_TASK_FILES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
PRESERVE_FILES_PATTERN - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
printConf(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfigUtil
 
PRIORITY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
processorContext - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
progress() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
progress() - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
Report progress.
progress() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
Report progress.
progress - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
progress() - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
PROGRESS_STATUS_LEN_LIMIT_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
PROGRESS_STATUS_LEN_LIMIT_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 

Q

QUEUE_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

R

readFields(DataInput) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
readFields(DataInput) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
readFields(DataInput) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
readFields(DataInput) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
readFields(DataInput) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
readFields(DataInput) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
readSplitMetaInfo(Configuration, FileSystem) - Static method in class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez
 
readSplits(Configuration) - Method in class org.apache.tez.mapreduce.input.MRInput
 
RECORDS_BEFORE_PROGRESS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
recoverTask(int, int) - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
REDUCE_CLASS_ATTR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_CPU_VCORES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_DEBUG_SCRIPT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_FAILURES_MAXPERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_INPUT_BUFFER_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_JAVA_OPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_LOG_LEVEL - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MARKRESET_BUFFER_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MARKRESET_BUFFER_SIZE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MAX_ATTEMPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MEMORY_PHYSICAL_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MEMORY_TOTAL_BYTES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MEMTOMEM_ENABLED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MEMTOMEM_THRESHOLD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_MERGE_INMEM_THRESHOLD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_SKIP_INCR_PROC_COUNT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCE_SKIP_MAXGROUPS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
REDUCEMEMORY_MB - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
ReduceProcessor - Class in org.apache.tez.mapreduce.processor.reduce
 
ReduceProcessor() - Constructor for class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 
registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos
 
removeSplits(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
renewDelegationToken(RenewDelegationTokenRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob
 
renewDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
RESOURCE_CALCULATOR_PROCESS_TREE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
ResourceMgrDelegate - Class in org.apache.tez.mapreduce.client
 
ResourceMgrDelegate(YarnConfiguration) - Constructor for class org.apache.tez.mapreduce.client.ResourceMgrDelegate
Delegate responsible for communicating with the Resource Manager's ApplicationClientProtocol.
run(Map<String, LogicalInput>, Map<String, LogicalOutput>) - Method in class org.apache.tez.mapreduce.processor.map.MapProcessor
 
run(Map<String, LogicalInput>, Map<String, LogicalOutput>) - Method in class org.apache.tez.mapreduce.processor.reduce.ReduceProcessor
 

S

setCleanupProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setConf(Configuration) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
setConf(Configuration) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
setConf(Configuration) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
setConf(Configuration) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
setConf(JobConf) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
setConfigurationBytes(ByteString) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional bytes configuration_bytes = 1;
setCounters(TezCounters) - Method in interface org.apache.tez.common.TezTaskStatus
 
setCounters(TezCounters) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setDesiredNumberOfSplits(int) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
setDesiredNumberOfSplits(int) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
setDiagnosticInfo(String) - Method in interface org.apache.tez.common.TezTaskStatus
 
setDiagnosticInfo(String) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setDisplayName(String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
setDisplayName(String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
setFailureInfo(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setFinishTime(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setFinishTime(long) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setFinishTime(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setHistoryFile(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setInputFormat(InputFormat<K, V>) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
setInputFormat(InputFormat<K, V>) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
setInputFormatName(String) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
setInputFormatNameBytes(ByteString) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional string input_format_name = 3;
setInputSplit(InputSplit) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
setJobACLs(Map<JobACL, AccessControlList>) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setJobID(JobID) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
Set the JobID.
setJobPriority(JobID, String) - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate
 
setJobPriority(JobID, String) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
setMapFinishTime(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setMapFinishTime(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setMapProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setNeededMem(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setNumPhysicalInputs(int) - Method in class org.apache.tez.mapreduce.input.MRInput
 
setNumPhysicalOutputs(int) - Method in class org.apache.tez.mapreduce.output.MROutput
 
setNumReservedSlots(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setNumUsedSlots(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setOutputSize(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setOutputSize(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setPhase(TezTaskStatus.Phase) - Method in interface org.apache.tez.common.TezTaskStatus
 
setPhase(TezTaskStatus.Phase) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setPriority(JobPriority) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setProgress(float) - Method in interface org.apache.tez.common.TezTaskStatus
 
setProgress(float) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
setProgress(float) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setProgress(float) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
setQueue(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setReduceProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setReservedMem(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setResourceMgrDelegate(ResourceMgrDelegate) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 
setRetired() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setRunState(TezTaskStatus.State) - Method in interface org.apache.tez.common.TezTaskStatus
 
setRunState(TezTaskStatus.State) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setSchedulingInfo(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setSetupProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setShuffleFinishTime(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setShuffleFinishTime(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setSortFinishTime(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setSortFinishTime(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setSplitBytes(ByteString) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional bytes split_bytes = 2;
setSplitClassName(String) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
setSplitClassNameBytes(ByteString) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.Builder
optional string split_class_name = 1;
setSplits(MRRuntimeProtos.MRSplitsProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
setSplits(MRRuntimeProtos.MRSplitsProto.Builder) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder
optional .MRSplitsProto splits = 2;
setSplits(int, MRRuntimeProtos.MRSplitProto) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
setSplits(int, MRRuntimeProtos.MRSplitProto.Builder) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
repeated .MRSplitProto splits = 2;
setStartTime(long) - Method in interface org.apache.tez.common.TezTaskStatus
 
setStartTime(long) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setStartTime(long) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setState(JobStatus.State) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setState(TezTaskStatus.State) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
setStateString(String) - Method in interface org.apache.tez.common.TezTaskStatus
 
setStateString(String) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
setStatus(String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter
 
setStatus(String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
Set the current status of the task to the given string.
setStatus(String) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
Set the current status of the task to the given string.
setStatus(String) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter
 
setTrackingUrl(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setUber(boolean) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
SETUP_CLEANUP_NEEDED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
setupJob(JobContext) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
setupOutput() - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter
 
setupTask(TaskAttemptContext) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
setUsedMem(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setUsername(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
setValue(long) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
setVersion(int) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto.Builder
optional int32 version = 1;
SHUFFLE_CONNECT_TIMEOUT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_FETCH_FAILURES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_INPUT_BUFFER_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_MEMORY_LIMIT_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_MERGE_PERCENT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_NOTIFY_READERROR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_PARALLEL_COPIES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_READ_TIMEOUT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SHUFFLE_SSL_ENABLED_DEFAULT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
SHUFFLE_SSL_ENABLED_KEY - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
size() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
size() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters
 
SKIP_OUTDIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SKIP_RECORDS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SKIP_START_ATTEMPTS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SPLIT_BYTES_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
SPLIT_CLASS_NAME_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
SPLIT_FILE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
SPLIT_METAINFO_MAXSIZE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
splitMetaInfo - Variable in class org.apache.tez.mapreduce.input.MRInput
 
SplitMetaInfoReaderTez - Class in org.apache.hadoop.mapreduce.split
A utility that reads the split meta info and creates split meta info objects
SplitMetaInfoReaderTez() - Constructor for class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez
 
SPLITS_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
SPLITS_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
start() - Method in class org.apache.tez.mapreduce.input.MRInput
 
start() - Method in class org.apache.tez.mapreduce.output.MROutput
 
STATIC_RESOLUTIONS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
statusUpdate(float, String, TezCounters) - Method in interface org.apache.tez.common.TezTaskStatus
 
statusUpdate(float, String, TezCounters) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
statusUpdate() - Method in class org.apache.tez.mapreduce.processor.MRTask
Send a status update to the task tracker
STDERR_LOGFILE_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
STDOUT_LOGFILE_ENV - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
submitJob(JobID, String, Credentials) - Method in class org.apache.tez.mapreduce.client.YARNRunner
 

T

TASK_ATTEMPT_ID - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_CLEANUP_NEEDED - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_DEBUGOUT_LINES - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_ID - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_ISMAP - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_LOCAL_OUTPUT_CLASS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
TASK_LOG_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
The log directory for the containers
TASK_LOG_SIZE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_MAP_PROFILE_PARAMS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_OUTPUT_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_PARTITION - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_PROFILE - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_PROFILE_PARAMS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_REDUCE_PROFILE_PARAMS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_TEMP_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_TIMEOUT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_TIMEOUT_CHECK_INTERVAL_MS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
TASK_USERLOG_LIMIT - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
taskAttemptContext - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
TaskAttemptContextImpl - Class in org.apache.tez.mapreduce.hadoop.mapred
 
TaskAttemptContextImpl(JobConf, TaskAttemptID, MRTaskReporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl
 
TaskAttemptContextImpl - Class in org.apache.tez.mapreduce.hadoop.mapreduce
 
TaskAttemptContextImpl(Configuration, TezTaskContext, boolean, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
TaskAttemptContextImpl(Configuration, TaskAttemptID, TezTaskContext, boolean, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
TaskAttemptContextImpl(Configuration, TaskAttemptID, TezTaskContext, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl
 
taskAttemptId - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
taskCleanup() - Method in class org.apache.tez.mapreduce.processor.MRTask
 
TaskInputOutputContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.tez.mapreduce.hadoop.mapreduce
A context object that allows input and output from the task.
TaskInputOutputContextImpl(Configuration, TaskAttemptID, RecordWriter<KEYOUT, VALUEOUT>, OutputCommitter, TezTaskContext, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
 
TEMP_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
TezGroupedSplit - Class in org.apache.hadoop.mapred.split
 
TezGroupedSplit() - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplit
 
TezGroupedSplit(int, String, String[], String) - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplit
 
TezGroupedSplit(int, String, String[]) - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplit
 
TezGroupedSplit - Class in org.apache.hadoop.mapreduce.split
 
TezGroupedSplit() - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
TezGroupedSplit(int, String, String[], String) - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
TezGroupedSplit(int, String, String[]) - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
TezGroupedSplitsInputFormat<K,V> - Class in org.apache.hadoop.mapred.split
 
TezGroupedSplitsInputFormat() - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat
 
TezGroupedSplitsInputFormat<K,V> - Class in org.apache.hadoop.mapreduce.split
 
TezGroupedSplitsInputFormat() - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat
 
TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader - Class in org.apache.hadoop.mapred.split
 
TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader(TezGroupedSplit, JobConf, Reporter) - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader - Class in org.apache.hadoop.mapreduce.split
 
TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader(TezGroupedSplit, TaskAttemptContext) - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
 
TezMapredSplitsGrouper - Class in org.apache.hadoop.mapred.split
 
TezMapredSplitsGrouper() - Constructor for class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper
 
TezMapReduceSplitsGrouper - Class in org.apache.hadoop.mapreduce.split
 
TezMapReduceSplitsGrouper() - Constructor for class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper
 
TezNullOutputCommitter - Class in org.apache.tez.mapreduce.hadoop.mapreduce
 
TezNullOutputCommitter() - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter
 
TezTaskStatus - Interface in org.apache.tez.common
 
TezTaskStatus.Phase - Enum in org.apache.tez.common
 
TezTaskStatus.State - Enum in org.apache.tez.common
 
TezTypeConverters - Class in org.apache.tez.mapreduce.hadoop
 
TezTypeConverters() - Constructor for class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 
toBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
toBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
toBuilder() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
toJobID(TezDAGID) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 
toMRJobId(TezDAGID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
toMRTaskAttemptId(TezTaskAttemptID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
toMRTaskId(TezTaskID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
toMRTaskIdForOutput(TezTaskID) - Static method in class org.apache.tez.mapreduce.hadoop.IDConverter
 
toString() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
toTez(TaskAttemptId) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 
toYarn(TezTaskStatus.Phase) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 
toYarn(TezTaskAttemptID) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters
 
translateVertexConfToTez(Configuration, Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MultiStageMRConfToTezTranslator
Translates MR keys to Tez for the provided vertex conf.

U

ugi - Variable in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl
The UserGroupInformation object that has a reference to the current user
updateEnvironmentForMRAM(Configuration, Map<String, String>) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Setup environment for the AM based on MR-based configuration
updateEnvironmentForMRTasks(Configuration, Map<String, String>, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Setup classpath and other environment variables
updateLocalResourcesForInputSplits(FileSystem, InputSplitInfo, Map<String, LocalResource>) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers
Update provided localResources collection with the required local resources needed by MapReduce tasks with respect to Input splits.
useNewApi - Variable in class org.apache.tez.mapreduce.processor.MRTask
 
USER_LOG_RETAIN_HOURS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
USER_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
UTF8_CHUNK_SIZE - Static variable in class org.apache.tez.mapreduce.client.YARNRunner
 
Utils - Class in org.apache.tez.mapreduce.common
 
Utils() - Constructor for class org.apache.tez.mapreduce.common.Utils
 

V

valueOf(String) - Static method in enum org.apache.tez.common.TezTaskStatus.Phase
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.tez.common.TezTaskStatus.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.tez.mapreduce.hadoop.DeprecatedKeys.MultiStageKeys
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.tez.mapreduce.hadoop.InputSplitInfo.Type
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.tez.common.TezTaskStatus.Phase
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.tez.common.TezTaskStatus.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.tez.mapreduce.hadoop.DeprecatedKeys.MultiStageKeys
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.tez.mapreduce.hadoop.InputSplitInfo.Type
Returns an array containing the constants of this enum type, in the order they are declared.
VERSION_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
VERTEX_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 

W

waitBeforeCompletion(MRTaskReporter) - Method in class org.apache.tez.mapreduce.processor.MRTask
 
WORKDIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
WORKING_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig
 
write(DataOutput) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit
 
write(DataOutput) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit
 
write(DataOutput) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus
 
write(DataOutput) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter
 
write(DataOutput) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup
 
write(KEYOUT, VALUEOUT) - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl
Generate an output key/value pair.
write(DataOutput) - Method in class org.apache.tez.mapreduce.hadoop.MRTaskStatus
 
writeReplace() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
writeReplace() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
writeReplace() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 
writeTo(CodedOutputStream) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto
 
writeTo(CodedOutputStream) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto
 
writeTo(CodedOutputStream) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitsProto
 

Y

YARN_TEZ_FRAMEWORK_NAME - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig
 
YARNRunner - Class in org.apache.tez.mapreduce.client
This class enables the current JobClient (0.22 hadoop) to run on YARN-TEZ.
YARNRunner(Configuration) - Constructor for class org.apache.tez.mapreduce.client.YARNRunner
Yarn runner incapsulates the client interface of yarn
YARNRunner(Configuration, ResourceMgrDelegate) - Constructor for class org.apache.tez.mapreduce.client.YARNRunner
Similar to YARNRunner.YARNRunner(Configuration) but allowing injecting ResourceMgrDelegate.
YARNRunner(Configuration, ResourceMgrDelegate, ClientCache) - Constructor for class org.apache.tez.mapreduce.client.YARNRunner
Similar to YARNRunner.YARNRunner(Configuration, ResourceMgrDelegate) but allowing injecting ClientCache.
YarnTezClientProtocolProvider - Class in org.apache.tez.mapreduce.client
 
YarnTezClientProtocolProvider() - Constructor for class org.apache.tez.mapreduce.client.YarnTezClientProtocolProvider
 

A B C D E F G H I J K L M N O P Q R S T U V W Y

Copyright © 2014 Apache Software Foundation. All rights reserved.