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;

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

addSplit(InputSplit) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit

addSplit(InputSplit) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit

addSplit(SplitContainer) - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

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.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

build() - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

build() - Method in class org.apache.tez.mapreduce.input.MRInput.MRInputConfigBuilder

Create the DataSourceDescriptor

build() - Method in class org.apache.tez.mapreduce.output.MROutput.MROutputConfigBuilder

Create the DataSinkDescriptor

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;

clearGroupingEnabled() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder

optional bool grouping_enabled = 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;

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() - Method in class org.apache.tez.dag.api.client.MRDAGClient

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.input.MultiMRInput

close() - Method in class org.apache.tez.mapreduce.lib.MRReader

close() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

close() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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

configureMRApiUsage(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Update the provided configuration to use the new API (mapreduce) or the old API (mapred) based on the configured InputFormat, OutputFormat, Partitioner etc.

configureMRInputWithLegacySplitGeneration(Configuration, Path, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

Setup split generation on the client, with splits being distributed via the traditional MapReduce mechanism of distributing splits via the Distributed Cache.

contentEquals(Counters.Counter) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter

Deprecated.

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

createConfigBuilder(Configuration) - Static method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See TezSplitGrouper.newConfigBuilder(Configuration)

createConfigBuilder(Configuration, Class<?>) - Static method in class org.apache.tez.mapreduce.input.MRInput

Create an MRInput.MRInputConfigBuilder

createConfigBuilder(Configuration, Class<?>, String) - Static method in class org.apache.tez.mapreduce.input.MRInput

Create an MRInput.MRInputConfigBuilder for FileInputFormat or FileInputFormat format based InputFormats.

createConfigBuilder(Configuration, Class<?>) - Static method in class org.apache.tez.mapreduce.input.MRInputLegacy

Create an MRInput.MRInputConfigBuilder

createConfigBuilder(Configuration, Class<?>, String) - Static method in class org.apache.tez.mapreduce.input.MRInputLegacy

Create an MRInput.MRInputConfigBuilder for a FileInputFormat

createConfigBuilder(Configuration, Class<?>) - Static method in class org.apache.tez.mapreduce.input.MultiMRInput

Create an MultiMRInput.MultiMRInputConfigBuilder to configure a MultiMRInput

createConfigBuilder(Configuration, Class<?>) - Static method in class org.apache.tez.mapreduce.output.MROutput

Create an MROutput.MROutputConfigBuilder

createConfigBuilder(Configuration, Class<?>, String) - Static method in class org.apache.tez.mapreduce.output.MROutput

Create an MROutput.MROutputConfigBuilder for a FileOutputFormat or FileOutputFormat based OutputFormats.

createConfigBuilder(Configuration, Class<?>) - Static method in class org.apache.tez.mapreduce.output.MROutputLegacy

Create an MROutput.MROutputConfigBuilder

createConfigBuilder(Configuration, Class<?>, String) - Static method in class org.apache.tez.mapreduce.output.MROutputLegacy

Create an MROutput.MROutputConfigBuilder for a FileOutputFormat

createKey() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

createMockTaskAttemptID(long, int, int, int, int, 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(Configuration, MRRuntimeProtos.MRSplitsProto) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

createMRInputPayloadWithGrouping(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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.MRInputHelpers

Create an instance of InputSplit from the MRInput representation of a split.

createOldFormatSplitFromUserPayload(MRRuntimeProtos.MRSplitProto, SerializationFactory) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

Create an instance of InputSplit from the MRInput representation of a split.

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.MRInputHelpers

createSplitProto(InputSplit) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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

done() - Method in class org.apache.tez.mapreduce.processor.MRTask

E

equals(Object) - Method in class org.apache.tez.mapreduce.grouper.MapredSplitContainer

equals(Object) - Method in class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

equals(Object) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter

equals(Object) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup

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

Deprecated.

findCounter(String, String) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup

flush() - Method in class org.apache.tez.mapreduce.output.MROutput

Call this in the processor before finishing to ensure outputs that outputs have been flushed.

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

generateInputSplitsToMem(Configuration, boolean, int) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

Generates Input splits and stores them in a MRRuntimeProtos.MRSplitsProto instance.

generateSplitsInAM(boolean) - Method in class org.apache.tez.mapreduce.input.MRInput.MRInputConfigBuilder

Set whether splits should be generated in the Tez App Master (default true)

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

getApplicationId() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate

getApplicationIdString(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getApplicationReport() - Method in class org.apache.tez.dag.api.client.MRDAGClient

getApplicationReportInternal() - Method in class org.apache.tez.dag.api.client.MRDAGClient

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.

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

getConfigUpdates() - Method in class org.apache.tez.mapreduce.input.MRInput

MRInput sets some additional parameters like split location when using the new API.

getConfigUpdates() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

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(GetCountersRequest) - Method in class org.apache.tez.mapreduce.client.NotRunningJob

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

getCredentialsForSinkFileSystem(boolean) - Method in class org.apache.tez.mapreduce.output.MROutput.MROutputConfigBuilder

Get the credentials for the output from its FileSystems Use the method to turn this off when not using a FileSystem or when Credentials are not supported

getCredentialsForSourceFileSystem(boolean) - Method in class org.apache.tez.mapreduce.input.MRInput.MRInputConfigBuilder

Get the credentials for the inputPaths from their FileSystems Use the method to turn this off when not using a FileSystem or when Credentials are not supported

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.

getCurrentKey() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

getCurrentKey() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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.

getCurrentValue() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

getCurrentValue() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

getDagAttemptNumber(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getDAGClient(ApplicationId, TezConfiguration, FrameworkClient) - Static method in class org.apache.tez.client.MRTezClient

getDagIndex(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getDagName(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getDAGStatus(Set<StatusGetOpts>) - Method in class org.apache.tez.dag.api.client.MRDAGClient

getDAGStatus(Set<StatusGetOpts>, long) - Method in class org.apache.tez.dag.api.client.MRDAGClient

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

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

getEstimatedSize(InputSplit) - Method in interface org.apache.hadoop.mapred.split.SplitSizeEstimator

getEstimatedSize(InputSplit) - Method in interface org.apache.hadoop.mapreduce.split.SplitSizeEstimator

getEstimatedSize(SplitContainer) - Method in interface org.apache.tez.mapreduce.grouper.SplitSizeEstimatorWrapper

getEstimatedSize(SplitContainer) - Method in class org.apache.tez.mapreduce.grouper.SplitSizeEstimatorWrapperMapred

getEstimatedSize(SplitContainer) - Method in class org.apache.tez.mapreduce.grouper.SplitSizeEstimatorWrapperMapReduce

getExecutionContext() - Method in class org.apache.tez.dag.api.client.MRDAGClient

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 class org.apache.tez.mapreduce.client.DAGJobStatus

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() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit

getGroupedSplits(Configuration, InputSplit[], int, String) - Method in class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper

getGroupedSplits(Configuration, InputSplit[], int, String, SplitSizeEstimator) - Method in class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper

getGroupedSplits(Configuration, InputSplit[], int, String, SplitSizeEstimator, SplitLocationProvider) - Method in class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper

getGroupedSplits() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit

getGroupedSplits(Configuration, List<InputSplit>, int, String) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

getGroupedSplits(Configuration, List<InputSplit>, int, String, SplitSizeEstimator) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

getGroupedSplits(Configuration, List<InputSplit>, int, String, SplitSizeEstimator, SplitLocationProvider) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

getGroupedSplits(Configuration, List<SplitContainer>, int, String, SplitSizeEstimatorWrapper, SplitLocationProviderWrapper) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

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.

getGroupingEnabled() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder

optional bool grouping_enabled = 3;

getGroupingEnabled() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto

optional bool grouping_enabled = 3;

getGroupingEnabled() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder

optional bool grouping_enabled = 3;

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

getInputFormatClass() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl

Get the InputFormat class for the job.

getInputIndex(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getInputName(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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

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.

getJavaOptsForMRAM(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Generate JVM options based on MapReduce AM java options.

getJavaOptsForMRMapper(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Generate JVM options based on MapReduce mapper java options.

getJavaOptsForMRReducer(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Generate JVM options based on MapReduce reducer java options.

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

getKeyValueReaders() - Method in class org.apache.tez.mapreduce.input.MultiMRInput

getLength() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit

getLength() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit

getLength() - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

getLength() - Method in class org.apache.tez.mapreduce.grouper.MapredSplitContainer

getLength() - Method in class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

getLength() - Method in class org.apache.tez.mapreduce.grouper.SplitContainer

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

getLocations(InputSplit) - Method in interface org.apache.hadoop.mapred.split.SplitLocationProvider

getLocations() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplit

getLocations(InputSplit) - Method in interface org.apache.hadoop.mapreduce.split.SplitLocationProvider

getLocations() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit

getLocations() - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

getLogFileParams(JobID, TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.YARNRunner

getLogFilePath(JobID, TaskAttemptID) - Method in class org.apache.tez.mapreduce.client.ClientServiceDelegate

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

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.

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

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 interface org.apache.tez.mapreduce.hadoop.InputSplitInfo

Get new format splits.

getNewFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk

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

getNewRecordReader() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy

getNewSplitDetailsFromDisk(JobSplit.TaskSplitIndex, JobConf, TezCounter) - Static method in class org.apache.tez.mapreduce.lib.MRInputUtils

getNewSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto, Configuration) - Static method in class org.apache.tez.mapreduce.lib.MRInputUtils

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 interface org.apache.tez.mapreduce.hadoop.InputSplitInfo

Get old format splits.

getOldFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk

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

getOldSplitDetailsFromDisk(JobSplit.TaskSplitIndex, JobConf, TezCounter) - Static method in class org.apache.tez.mapreduce.lib.MRInputUtils

getOldSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto, Configuration) - Static method in class org.apache.tez.mapreduce.lib.MRInputUtils

getOutputCommitter() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl

getOutputCommitter() - Method in class org.apache.tez.mapreduce.output.MROutputLegacy

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.

getPos() - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

getPreferredLocations(SplitContainer) - Method in class org.apache.hadoop.mapreduce.split.SplitLocationProviderMapReduce

getPreferredLocations() - Method in class org.apache.tez.mapreduce.grouper.MapredSplitContainer

getPreferredLocations() - Method in class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

getPreferredLocations() - Method in class org.apache.tez.mapreduce.grouper.SplitContainer

getPreferredLocations(SplitContainer) - Method in interface org.apache.tez.mapreduce.grouper.SplitLocationProviderWrapper

getPreferredLocations(SplitContainer) - Method in class org.apache.tez.mapreduce.grouper.SplitLocationProviderWrapperMapred

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 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.input.MRInput

getProgress() - Method in class org.apache.tez.mapreduce.lib.MRReader

getProgress() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

getProgress() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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

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

getRack() - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

getRawSplit() - Method in class org.apache.tez.mapreduce.grouper.MapredSplitContainer

getRawSplit() - Method in class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

getReader() - Method in class org.apache.tez.mapreduce.input.base.MRInputBase

getReader() - Method in class org.apache.tez.mapreduce.input.MRInput

Returns a KeyValueReader that can be used to read Map Reduce compatible key value data.

getReader() - Method in class org.apache.tez.mapreduce.input.MultiMRInput

getRecordReader(InputSplit, JobConf, Reporter) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat

getRecordReader() - Method in class org.apache.tez.mapreduce.lib.MRReader

getRecordReader() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

getRecordReader() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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.

getReservedMem() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

getResourceForMRMapper(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Extract the container resource requirements from the provided configuration, which would otherwise have been used when running a Hadoop MapReduce mapper.

getResourceForMRReducer(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Extract the container resource requirements from the provided configuration, which would otherwise have been used when running a Hadoop MapReduce reducer.

getRootQueues() - Method in class org.apache.tez.mapreduce.client.ResourceMgrDelegate

getRootQueues() - Method in class org.apache.tez.mapreduce.client.YARNRunner

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

getSortComparator() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl

Get the RawComparator comparator used to compare keys.

getSplit() - Method in class org.apache.tez.mapreduce.lib.MRReader

getSplit() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

getSplit() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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 class org.apache.tez.mapreduce.client.DAGJobStatus

getState() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

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 class org.apache.tez.mapreduce.hadoop.mapred.TaskAttemptContextImpl

Get the taskAttemptID.

getTaskAttemptId() - Method in class org.apache.tez.mapreduce.processor.MRTask

getTaskAttemptIndex(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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

getTaskIndex(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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

getUniqueIdentifier(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

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;

getVertexIndex(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

* @see TaskContext.getTaskVertexIndex()

getVertexName(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

getVertexStatus(String, Set<StatusGetOpts>) - Method in class org.apache.tez.dag.api.client.MRDAGClient

getWorkingDirectory() - Method in class org.apache.tez.mapreduce.hadoop.mapreduce.JobContextImpl

Get the current working directory for the default file system.

getWrappedInputFormatName() - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

getWrappedSplitContainers() - Method in class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

getWriter() - Method in class org.apache.tez.mapreduce.output.MROutput

Get a key value write to write Map Reduce compatible output

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

GroupedSplitContainer - Class in org.apache.tez.mapreduce.grouper

An entity to hold grouped splits - either mapred or mapreduce.

GroupedSplitContainer(int, String, String[], String) - Constructor for class org.apache.tez.mapreduce.grouper.GroupedSplitContainer

GROUPING_ENABLED_FIELD_NUMBER - Static variable in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto

groupSplits(boolean) - Method in class org.apache.tez.mapreduce.input.MRInput.MRInputConfigBuilder

Set whether splits should be grouped (default true)

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.input.MultiMRInput

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

handleInputInitializerEvent(List<InputInitializerEvent>) - Method in class org.apache.tez.mapreduce.common.MRInputAMSplitGenerator

handleInputInitializerEvent(List<InputInitializerEvent>) - Method in class org.apache.tez.mapreduce.common.MRInputSplitDistributor

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;

hasGroupingEnabled() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder

optional bool grouping_enabled = 3;

hasGroupingEnabled() - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto

optional bool grouping_enabled = 3;

hasGroupingEnabled() - Method in interface org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder

optional bool grouping_enabled = 3;

hashCode() - Method in class org.apache.tez.mapreduce.grouper.MapredSplitContainer

hashCode() - Method in class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

hashCode() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounter

hashCode() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup

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

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 interface org.apache.tez.mapreduce.hadoop.InputSplitInfo

Check whether the current instance is using old / new format splits

holdsNewFormatSplits() - Method in class org.apache.tez.mapreduce.hadoop.InputSplitInfoDisk

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() - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter

initialize() - Method in class org.apache.tez.mapreduce.common.MRInputAMSplitGenerator

initialize() - Method in class org.apache.tez.mapreduce.common.MRInputSplitDistributor

initialize() - Method in class org.apache.tez.mapreduce.input.base.MRInputBase

initialize() - Method in class org.apache.tez.mapreduce.input.MRInput

initialize() - Method in class org.apache.tez.mapreduce.input.MultiMRInput

initialize() - Method in class org.apache.tez.mapreduce.output.MROutput

initialize() - Method in class org.apache.tez.mapreduce.processor.MRTask

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

inputRecordCounter - Variable in class org.apache.tez.mapreduce.input.base.MRInputBase

inputSplit - Variable in class org.apache.tez.mapreduce.lib.MRReaderMapred

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<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<TaskLocationHint>, int, Credentials, Configuration) - Constructor for class org.apache.tez.mapreduce.hadoop.InputSplitInfoMem

InputSplitInfoMem(InputSplit[], List<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

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

isJobComplete() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

isProcessed() - Method in class org.apache.tez.mapreduce.grouper.SplitContainer

isRetired() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

isSetup() - Method in class org.apache.tez.mapreduce.lib.MRReader

isSetup() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

isSetup() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

isTaskRecoverySupported() - Method in class org.apache.tez.mapreduce.committer.MROutputCommitter

isUber() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

isUsingNewApi() - Method in class org.apache.tez.mapreduce.input.MRInputLegacy

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 class org.apache.tez.common.MRFrameworkConfigs

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.input.base.MRInputBase

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

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, TaskContext, 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(ProcessorContext) - 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

MapredSplitContainer - Class in org.apache.tez.mapreduce.grouper

MapredSplitContainer(InputSplit) - Constructor for class org.apache.tez.mapreduce.grouper.MapredSplitContainer

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

MapReduceSplitContainer - Class in org.apache.tez.mapreduce.grouper

MapReduceSplitContainer(InputSplit) - Constructor for class org.apache.tez.mapreduce.grouper.MapReduceSplitContainer

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

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_PAYLOAD - Static variable in interface org.apache.tez.mapreduce.hadoop.MRJobConfig

MR_TEZ_INPUT_INITIALIZER_SERIALIZE_EVENT_PAYLOAD_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

Implements a Map Reduce compatible combiner

MRCombiner(TaskContext) - 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

MRDAGClient - Class in org.apache.tez.dag.api.client

MRDAGClient(DAGClient) - Constructor for class org.apache.tez.dag.api.client.MRDAGClient

MRFrameworkConfigs - Class in org.apache.tez.common

MRFrameworkConfigs() - Constructor for class org.apache.tez.common.MRFrameworkConfigs

MRHelpers - Class in org.apache.tez.mapreduce.hadoop

This class contains helper methods for frameworks which migrate from MapReduce to Tez, and need to continue to work with existing MapReduce configurations.

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(InputContext, int) - Constructor for class org.apache.tez.mapreduce.input.MRInput

MRInput.MRInputConfigBuilder - Class in org.apache.tez.mapreduce.input

Helper class to configure MRInput

MRInputAMSplitGenerator - Class in org.apache.tez.mapreduce.common

Implements an InputInitializer that generates Map Reduce splits in the App Master.

MRInputAMSplitGenerator(InputInitializerContext) - Constructor for class org.apache.tez.mapreduce.common.MRInputAMSplitGenerator

MRInputBase - Class in org.apache.tez.mapreduce.input.base

MRInputBase(InputContext, int) - Constructor for class org.apache.tez.mapreduce.input.base.MRInputBase

MRInputHelpers - Class in org.apache.tez.mapreduce.hadoop

MRInputHelpers() - Constructor for class org.apache.tez.mapreduce.hadoop.MRInputHelpers

MRInputLegacy - Class in org.apache.tez.mapreduce.input

MRInputLegacy(InputContext, int) - Constructor for class org.apache.tez.mapreduce.input.MRInputLegacy

MRInputSplitDistributor - Class in org.apache.tez.mapreduce.common

Implements an InputInitializer that distributes Map Reduce splits created by the client to tasks in the Vertex This can be used when certain reasons (e.g.

MRInputSplitDistributor(InputInitializerContext) - Constructor for class org.apache.tez.mapreduce.common.MRInputSplitDistributor

MRInputUtils - Class in org.apache.tez.mapreduce.lib

Helper methods for InputFormat based Inputs.

MRInputUtils() - Constructor for class org.apache.tez.mapreduce.lib.MRInputUtils

MRJobConfig - Interface in org.apache.tez.mapreduce.hadoop

MROutput - Class in org.apache.tez.mapreduce.output

MROutput is an Output which allows key/values pairs to be written by a processor.

MROutput(OutputContext, int) - Constructor for class org.apache.tez.mapreduce.output.MROutput

MROutput.MROutputConfigBuilder - Class in org.apache.tez.mapreduce.output

Helper class to configure MROutput

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

MROutputCommitter - Class in org.apache.tez.mapreduce.committer

Implements the OutputCommitter and provide Map Reduce compatible output commit operations for Map Reduce compatible data sinks.

MROutputCommitter(OutputCommitterContext) - Constructor for class org.apache.tez.mapreduce.committer.MROutputCommitter

MROutputLegacy - Class in org.apache.tez.mapreduce.output

MROutputLegacy(OutputContext, int) - Constructor for class org.apache.tez.mapreduce.output.MROutputLegacy

MRPartitioner - Class in org.apache.tez.mapreduce.partition

Provides an implementation of Partitioner that is compatible with Map Reduce partitioners.

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

mrReader - Variable in class org.apache.tez.mapreduce.input.MRInput

MRReader - Class in org.apache.tez.mapreduce.lib

MRReader(InputContext) - Constructor for class org.apache.tez.mapreduce.lib.MRReader

MRReaderMapred - Class in org.apache.tez.mapreduce.lib

MRReaderMapred(JobConf, TezCounters, TezCounter, InputContext) - Constructor for class org.apache.tez.mapreduce.lib.MRReaderMapred

MRReaderMapred(JobConf, InputSplit, TezCounters, TezCounter, InputContext) - Constructor for class org.apache.tez.mapreduce.lib.MRReaderMapred

MRReaderMapReduce - Class in org.apache.tez.mapreduce.lib

MRReaderMapReduce(JobConf, TezCounters, TezCounter, long, int, int, int, int, InputContext) - Constructor for class org.apache.tez.mapreduce.lib.MRReaderMapReduce

MRReaderMapReduce(JobConf, InputSplit, TezCounters, TezCounter, long, int, int, int, int, InputContext) - Constructor for class org.apache.tez.mapreduce.lib.MRReaderMapReduce

MRReporter - Class in org.apache.tez.mapreduce.hadoop.mapred

MRReporter(TezCounters) - Constructor for class org.apache.tez.mapreduce.hadoop.mapred.MRReporter

MRReporter(TezCounters, 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(ProcessorContext, boolean) - Constructor for class org.apache.tez.mapreduce.processor.MRTask

MRTaskReporter - Class in org.apache.tez.mapreduce.processor

MRTaskReporter(ProcessorContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter

MRTaskReporter(OutputContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter

MRTaskReporter(InputContext) - Constructor for class org.apache.tez.mapreduce.processor.MRTaskReporter

MRTezClient - Class in org.apache.tez.client

MRTezClient(String, TezConfiguration, boolean, Map<String, LocalResource>, Credentials) - Constructor for class org.apache.tez.client.MRTezClient

MultiMRInput - Class in org.apache.tez.mapreduce.input

MultiMRInput(InputContext, int) - Constructor for class org.apache.tez.mapreduce.input.MultiMRInput

MultiMRInput.MultiMRInputConfigBuilder - Class in org.apache.tez.mapreduce.input

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

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

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

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

newConfigBuilder(Configuration) - Static method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Builder that can be used to configure grouping in Tez

next(K, V) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

next() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

next() - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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

notifyDone() - Method in class org.apache.tez.mapreduce.lib.MRReader

notifyProgress() - Method in class org.apache.tez.mapreduce.lib.MRReader

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

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.client - package org.apache.tez.client

org.apache.tez.common - package org.apache.tez.common

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.tez.dag.api.client - package org.apache.tez.dag.api.client

org.apache.tez.mapreduce.client - package org.apache.tez.mapreduce.client

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

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.grouper - package org.apache.tez.mapreduce.grouper

org.apache.tez.mapreduce.hadoop - package org.apache.tez.mapreduce.hadoop

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.tez.mapreduce.hadoop.mapred - package org.apache.tez.mapreduce.hadoop.mapred

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.tez.mapreduce.hadoop.mapreduce - package org.apache.tez.mapreduce.hadoop.mapreduce

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.tez.mapreduce.input - package org.apache.tez.mapreduce.input

org.apache.tez.mapreduce.input.base - package org.apache.tez.mapreduce.input.base

org.apache.tez.mapreduce.lib - package org.apache.tez.mapreduce.lib

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

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(UserPayload) - Static method in class org.apache.tez.mapreduce.hadoop.MRInputHelpers

Parse the payload used by MRInputPayload

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

postOp() - Method in class org.apache.tez.mapreduce.processor.SimpleMRProcessor

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

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

readSplitMetaInfo(Configuration, FileSystem) - Static method in class org.apache.hadoop.mapreduce.split.SplitMetaInfoReaderTez

readSplits(Configuration) - Static method in class org.apache.tez.mapreduce.lib.MRInputUtils

recordReader - Variable in class org.apache.tez.mapreduce.lib.MRReaderMapred

recordReader - Variable in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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(ProcessorContext) - 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;

setCustomInitializerDescriptor(InputInitializerDescriptor) - Method in class org.apache.tez.mapreduce.input.MRInput.MRInputConfigBuilder

This method is intended to be used in case a custom InputInitializer is being used along with MRInput.

setDesiredNumberOfSplits(int) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat

setDesiredNumberOfSplits(int) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat

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

setDoCommit(boolean) - Method in class org.apache.tez.mapreduce.output.MROutput.MROutputConfigBuilder

Disable commit operations for the output (default: true) If the value is set to false then no OutputCommitter will be specified for the output

setFailureInfo(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setFinishTime(long) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setGroupingEnabled(boolean) - Method in class org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRInputUserPayloadProto.Builder

optional bool grouping_enabled = 3;

setGroupingRackSplitSizeReduction(float) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

setGroupingRackSplitSizeReduction(float) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

setGroupingSplitSize(long, long) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

upper and lower bounds for the splits

setGroupingSplitSize(long, long) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

upper and lower bounds for the splits

setGroupSplitByCount(boolean) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

setGroupSplitByCount(boolean) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

setGroupSplitByLength(boolean) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

setGroupSplitByLength(boolean) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

setGroupSplitCount(int) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

setGroupSplitCount(int) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

setGroupSplitWaves(float) - Method in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder

Deprecated.

setGroupSplitWaves(float) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

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

setInputSplit(InputSplit) - Method in class org.apache.tez.mapreduce.processor.MRTaskReporter

setIsProcessed(boolean) - Method in class org.apache.tez.mapreduce.grouper.SplitContainer

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

setMapProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setNeededMem(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setNodeLocalGroupsOnly(boolean) - Method in class org.apache.tez.mapreduce.grouper.TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

setNumReservedSlots(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setNumUsedSlots(int) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setPriority(JobPriority) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setProgress(float) - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRReporter

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

setSchedulingInfo(String) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setSetupProgress(float) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setSplit(Object) - Method in class org.apache.tez.mapreduce.lib.MRReader

setSplit(Object) - Method in class org.apache.tez.mapreduce.lib.MRReaderMapred

setSplit(Object) - Method in class org.apache.tez.mapreduce.lib.MRReaderMapReduce

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;

setSplitLocationProvider(SplitLocationProvider) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat

setSplitLocationProvider(SplitLocationProvider) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat

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;

setSplitSizeEstimator(SplitSizeEstimator) - Method in class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat

setSplitSizeEstimator(SplitSizeEstimator) - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat

setStartTime(long) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

setState(JobStatus.State) - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

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

SimpleMRProcessor - Class in org.apache.tez.mapreduce.processor

A SimpleProcessor that provides Map Reduce specific post processing by calling commit (if needed) on all MROutputs connected to this Processor.

SimpleMRProcessor(ProcessorContext) - Constructor for class org.apache.tez.mapreduce.processor.SimpleMRProcessor

size() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters.MRCounterGroup

size() - Method in class org.apache.tez.mapreduce.hadoop.mapred.MRCounters

Deprecated.

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

SplitContainer - Class in org.apache.tez.mapreduce.grouper

SplitContainer() - Constructor for class org.apache.tez.mapreduce.grouper.SplitContainer

SplitLocationProvider - Interface in org.apache.hadoop.mapred.split

Provides location information for the given split

SplitLocationProvider - Interface in org.apache.hadoop.mapreduce.split

Provides location information for the given split

SplitLocationProviderMapReduce - Class in org.apache.hadoop.mapreduce.split

SplitLocationProviderMapReduce(SplitLocationProvider) - Constructor for class org.apache.hadoop.mapreduce.split.SplitLocationProviderMapReduce

SplitLocationProviderWrapper - Interface in org.apache.tez.mapreduce.grouper

SplitLocationProviderWrapperMapred - Class in org.apache.tez.mapreduce.grouper

SplitLocationProviderWrapperMapred(SplitLocationProvider) - Constructor for class org.apache.tez.mapreduce.grouper.SplitLocationProviderWrapperMapred

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

SplitSizeEstimator - Interface in org.apache.hadoop.mapred.split

SplitSizeEstimator - Interface in org.apache.hadoop.mapreduce.split

SplitSizeEstimatorWrapper - Interface in org.apache.tez.mapreduce.grouper

An interface to handle split size estimation across mapred and mapreduce splits

SplitSizeEstimatorWrapperMapred - Class in org.apache.tez.mapreduce.grouper

SplitSizeEstimatorWrapperMapred(SplitSizeEstimator) - Constructor for class org.apache.tez.mapreduce.grouper.SplitSizeEstimatorWrapperMapred

SplitSizeEstimatorWrapperMapReduce - Class in org.apache.tez.mapreduce.grouper

SplitSizeEstimatorWrapperMapReduce(SplitSizeEstimator) - Constructor for class org.apache.tez.mapreduce.grouper.SplitSizeEstimatorWrapperMapReduce

start() - Method in class org.apache.tez.mapreduce.input.MRInput

start() - Method in class org.apache.tez.mapreduce.input.MultiMRInput

start() - Method in class org.apache.tez.mapreduce.output.MROutput

STATIC_RESOLUTIONS - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig

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

submitDAGApplication(ApplicationId, DAG) - Method in class org.apache.tez.client.MRTezClient

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_LOCAL_RESOURCE_DIR - Static variable in class org.apache.tez.common.MRFrameworkConfigs

The directory which contains the localized files for this task.

TASK_LOCAL_RESOURCE_DIR_DEFAULT - Static variable in class org.apache.tez.common.MRFrameworkConfigs

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, TezCounters, long, int, int, int, int, boolean, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl

TaskAttemptContextImpl(Configuration, TaskAttemptID, TezCounters, boolean, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskAttemptContextImpl

TaskAttemptContextImpl(Configuration, TaskAttemptID, TezCounters, 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, TaskContext, Reporter) - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TaskInputOutputContextImpl

TEMP_DIR - Static variable in interface org.apache.tez.mapreduce.hadoop.MRConfig

TEZ_GROUPING_NODE_LOCAL_ONLY - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Generate node local splits only.

TEZ_GROUPING_NODE_LOCAL_ONLY_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_RACK_SPLIT_SIZE_REDUCTION - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_RACK_SPLIT_SIZE_REDUCTION - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

This factor is used to decrease the per group desired (length and count) limits for groups created by combining splits within a rack.

TEZ_GROUPING_RACK_SPLIT_SIZE_REDUCTION_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_RACK_SPLIT_SIZE_REDUCTION_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_REPEATABLE - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_REPEATABLE - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Repeated invocations of grouping on the same splits with the same parameters will produce the same groups.

TEZ_GROUPING_REPEATABLE_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_REPEATABLE_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_COUNT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_COUNT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Limit the number of splits in a group by the number of splits in the group

TEZ_GROUPING_SPLIT_BY_COUNT_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_COUNT_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_LENGTH - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_LENGTH - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Limit the number of splits in a group by the total length of the splits in the group

TEZ_GROUPING_SPLIT_BY_LENGTH_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_BY_LENGTH_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_SPLIT_COUNT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_COUNT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Specify the number of splits desired to be created

TEZ_GROUPING_SPLIT_MAX_SIZE - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_MAX_SIZE - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Upper bound on the size (in bytes) of a grouped split, to avoid generating excessively large splits.

TEZ_GROUPING_SPLIT_MAX_SIZE_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_MAX_SIZE_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_SPLIT_MIN_SIZE - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_MIN_SIZE - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

Lower bound on the size (in bytes) of a grouped split, to avoid generating too many small splits.

TEZ_GROUPING_SPLIT_MIN_SIZE_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_MIN_SIZE_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_GROUPING_SPLIT_WAVES - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_WAVES - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

The multiplier for available queue capacity when determining number of tasks for a Vertex.

TEZ_GROUPING_SPLIT_WAVES_DEFAULT - Static variable in class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

Deprecated.

See equivalent in TezSplitGrouper

TEZ_GROUPING_SPLIT_WAVES_DEFAULT - Static variable in class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TEZ_MAPREDUCE_APPLICATION_ID - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_DAG_ATTEMPT_NUMBER - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_DAG_INDEX - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_DAG_NAME - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_INPUT_INDEX - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_INPUT_NAME - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_TASK_ATTEMPT_INDEX - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_TASK_INDEX - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_UNIQUE_IDENTIFIER - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_VERTEX_INDEX - Static variable in class org.apache.tez.mapreduce.input.MRInput

TEZ_MAPREDUCE_VERTEX_NAME - Static variable in class org.apache.tez.mapreduce.input.MRInput

TezGroupedSplit - Class in org.apache.hadoop.mapred.split

Implements an InputSplit that provides a generic wrapper around a group of real InputSplits

TezGroupedSplit() - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplit

TezGroupedSplit(List<InputSplit>, String, String[], String, long) - 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

A Mapreduce InputSplit that provides a generic wrapper around a set of real InputSplits.

TezGroupedSplit() - Constructor for class org.apache.hadoop.mapreduce.split.TezGroupedSplit

TezGroupedSplit(List<InputSplit>, String, String[], String, long) - 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

An InputFormat that provides a generic grouping around the splits of a real InputFormat

TezGroupedSplitsInputFormat() - Constructor for class org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat

TezGroupedSplitsInputFormat<K,V> - Class in org.apache.hadoop.mapreduce.split

An InputFormat that provides a generic grouping around the splits of a real InputFormat

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

A Helper that provides grouping logic to group InputSplits using various parameters.

TezMapredSplitsGrouper() - Constructor for class org.apache.hadoop.mapred.split.TezMapredSplitsGrouper

TezMapReduceSplitsGrouper - Class in org.apache.hadoop.mapreduce.split

Helper that provides a grouping of input splits based on multiple parameters.

TezMapReduceSplitsGrouper() - Constructor for class org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

TezMapReduceSplitsGrouper.TezMRSplitsGrouperConfigBuilder - Class in org.apache.hadoop.mapreduce.split

Deprecated.

See TezSplitGrouper.TezMRSplitsGrouperConfigBuilder

TezNullOutputCommitter - Class in org.apache.tez.mapreduce.hadoop.mapreduce

TezNullOutputCommitter() - Constructor for class org.apache.tez.mapreduce.hadoop.mapreduce.TezNullOutputCommitter

TezSplitGrouper - Class in org.apache.tez.mapreduce.grouper

TezSplitGrouper() - Constructor for class org.apache.tez.mapreduce.grouper.TezSplitGrouper

TezSplitGrouper.TezMRSplitsGrouperConfigBuilder - Class in org.apache.tez.mapreduce.grouper

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.hadoop.mapred.split.TezGroupedSplit

toString() - Method in class org.apache.hadoop.mapreduce.split.TezGroupedSplit

toString() - Method in class org.apache.tez.mapreduce.client.DAGJobStatus

toTez(TaskAttemptId) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters

toYarn(TezTaskAttemptID) - Static method in class org.apache.tez.mapreduce.hadoop.TezTypeConverters

translateMRConfToTez(Configuration) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Translate MapReduce configuration keys to the equivalent Tez keys in the provided configuration.

translateMRConfToTez(Configuration, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Translate MapReduce configuration keys to the equivalent Tez keys in the provided configuration.

tryKillDAG() - Method in class org.apache.tez.dag.api.client.MRDAGClient

U

updateEnvBasedOnMRAMEnv(Configuration, Map<String, String>) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Setup environment variables based on the configured values for the MR AM

updateEnvBasedOnMRTaskEnv(Configuration, Map<String, String>, boolean) - Static method in class org.apache.tez.mapreduce.hadoop.MRHelpers

Setup classpath and other environment variables based on the configured values for MR Mappers or Reducers

useNewApi - Variable in class org.apache.tez.mapreduce.input.base.MRInputBase

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.mapreduce.hadoop.InputSplitInfo.Type

Returns the enum constant of this type with the specified name.

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

waitForCompletion() - Method in class org.apache.tez.dag.api.client.MRDAGClient

waitForCompletionWithStatusUpdates(Set<StatusGetOpts>) - Method in class org.apache.tez.dag.api.client.MRDAGClient

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.

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