TableTaskAttemptContext (Oracle NoSQL Database API)

java.lang.Object
- oracle.kv.hadoop.hive.table.TableTaskAttemptContext

All Implemented Interfaces:

JobContext, MRJobConfig, TaskAttemptContext, Progressable
```
public class TableTaskAttemptContext
extends Object
implements TaskAttemptContext
```
Concrete implementation of Hadoop TaskAttemptContext interface. When initializing a YARN based (MapReduce version 2) RecordReader, an instance of TaskAttemptContext must be specified. This class is intended to satisfy that requirement. Note that the RecordReader provided for Hadoop integration is YARN based, whereas the Hive infrastructure requires a RecordReader based on version 1 MapReduce. To address this incompatibility when integrating with HIVE, a version 1 based RecordReader is used, but wraps and delegates to a version 2 RecordReader; thus, the need for this class. Currently, the methods of this class are "stubbed out" and/or return default values; which seems to be acceptable for the Hive integration.

Field Summary
- Fields inherited from interface org.apache.hadoop.mapreduce.MRJobConfig
  APPLICATION_ATTEMPT_ID, APPLICATION_MASTER_CLASS, CACHE_ARCHIVES, CACHE_ARCHIVES_SIZES, CACHE_ARCHIVES_TIMESTAMPS, CACHE_ARCHIVES_VISIBILITIES, CACHE_FILE_TIMESTAMPS, CACHE_FILE_VISIBILITIES, CACHE_FILES, CACHE_FILES_SIZES, CACHE_LOCALARCHIVES, CACHE_LOCALFILES, CACHE_SYMLINK, CLASSPATH_ARCHIVES, CLASSPATH_FILES, COMBINE_CLASS_ATTR, COMBINE_RECORDS_BEFORE_PROGRESS, COMBINER_GROUP_COMPARATOR_CLASS, COMPLETED_MAPS_FOR_REDUCE_SLOWSTART, COUNTER_GROUP_NAME_MAX_DEFAULT, COUNTER_GROUP_NAME_MAX_KEY, COUNTER_GROUPS_MAX_DEFAULT, COUNTER_GROUPS_MAX_KEY, COUNTER_NAME_MAX_DEFAULT, COUNTER_NAME_MAX_KEY, COUNTERS_MAX_DEFAULT, COUNTERS_MAX_KEY, DEFAULT_JOB_ACL_MODIFY_JOB, DEFAULT_JOB_ACL_VIEW_JOB, DEFAULT_JOB_AM_ACCESS_DISABLED, DEFAULT_JOB_TOKEN_TRACKING_IDS_ENABLED, DEFAULT_LOG_LEVEL, DEFAULT_MAP_CPU_VCORES, DEFAULT_MAP_MEMORY_MB, DEFAULT_MAPRED_ADMIN_JAVA_OPTS, DEFAULT_MAPRED_ADMIN_USER_ENV, DEFAULT_MAPREDUCE_APPLICATION_CLASSPATH, DEFAULT_MAPREDUCE_CROSS_PLATFORM_APPLICATION_CLASSPATH, DEFAULT_MAX_SHUFFLE_FETCH_RETRY_DELAY, DEFAULT_MR_AM_ADMIN_COMMAND_OPTS, DEFAULT_MR_AM_COMMAND_OPTS, DEFAULT_MR_AM_COMMIT_WINDOW_MS, DEFAULT_MR_AM_COMMITTER_CANCEL_TIMEOUT_MS, DEFAULT_MR_AM_CONTAINERLAUNCHER_THREAD_COUNT_LIMIT, DEFAULT_MR_AM_CPU_VCORES, DEFAULT_MR_AM_HISTORY_COMPLETE_EVENT_FLUSH_TIMEOUT_MS, DEFAULT_MR_AM_HISTORY_JOB_COMPLETE_UNFLUSHED_MULTIPLIER, DEFAULT_MR_AM_HISTORY_MAX_UNFLUSHED_COMPLETE_EVENTS, DEFAULT_MR_AM_HISTORY_USE_BATCHED_FLUSH_QUEUE_SIZE_THRESHOLD, DEFAULT_MR_AM_IGNORE_BLACKLISTING_BLACKLISTED_NODE_PERCENT, DEFAULT_MR_AM_JOB_CLIENT_THREAD_COUNT, DEFAULT_MR_AM_JOB_REDUCE_PREEMPTION_LIMIT, DEFAULT_MR_AM_JOB_REDUCE_RAMP_UP_LIMIT, DEFAULT_MR_AM_LOG_BACKUPS, DEFAULT_MR_AM_LOG_KB, DEFAULT_MR_AM_LOG_LEVEL, DEFAULT_MR_AM_MAX_ATTEMPTS, DEFAULT_MR_AM_NUM_PROGRESS_SPLITS, DEFAULT_MR_AM_STAGING_DIR, DEFAULT_MR_AM_TASK_ESTIMATOR_SMOOTH_LAMBDA_MS, DEFAULT_MR_AM_TASK_LISTENER_THREAD_COUNT, DEFAULT_MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS, DEFAULT_MR_AM_TO_RM_WAIT_INTERVAL_MS, DEFAULT_MR_AM_VMEM_MB, DEFAULT_MR_CLIENT_MAX_RETRIES, DEFAULT_MR_CLIENT_TO_AM_IPC_MAX_RETRIES, DEFAULT_MR_CLIENT_TO_AM_IPC_MAX_RETRIES_ON_TIMEOUTS, DEFAULT_MR_JOB_END_NOTIFICATION_TIMEOUT, DEFAULT_REDUCE_CPU_VCORES, DEFAULT_REDUCE_MEMORY_MB, DEFAULT_SHELL, DEFAULT_SPLIT_METAINFO_MAXSIZE, DEFAULT_TASK_LOG_BACKUPS, GROUP_COMPARATOR_CLASS, HADOOP_WORK_DIR, ID, INDEX_CACHE_MEMORY_LIMIT, INPUT_FORMAT_CLASS_ATTR, IO_SORT_FACTOR, IO_SORT_MB, JAR, JAR_UNPACK_PATTERN, JOB_ACL_MODIFY_JOB, JOB_ACL_VIEW_JOB, JOB_AM_ACCESS_DISABLED, JOB_CANCEL_DELEGATION_TOKEN, JOB_CONF_FILE, JOB_JAR, JOB_JOBTRACKER_ID, JOB_LOCAL_DIR, JOB_NAME, JOB_NAMENODES, JOB_SPLIT, JOB_SPLIT_METAINFO, JOB_SUBMIT_DIR, JOB_SUBMITHOST, JOB_SUBMITHOSTADDR, JOB_TAGS, JOB_TOKEN_TRACKING_IDS, JOB_TOKEN_TRACKING_IDS_ENABLED, JOB_UBERTASK_ENABLE, JOB_UBERTASK_MAXBYTES, JOB_UBERTASK_MAXMAPS, JOB_UBERTASK_MAXREDUCES, JVM_NUMTASKS_TORUN, KEY_COMPARATOR, MAP_CLASS_ATTR, MAP_COMBINE_MIN_SPILLS, MAP_CPU_VCORES, MAP_DEBUG_SCRIPT, MAP_ENV, MAP_FAILURES_MAX_PERCENT, MAP_INPUT_FILE, MAP_INPUT_PATH, MAP_INPUT_START, MAP_JAVA_OPTS, MAP_LOG_LEVEL, MAP_MAX_ATTEMPTS, MAP_MEMORY_MB, MAP_OUTPUT_COLLECTOR_CLASS_ATTR, MAP_OUTPUT_COMPRESS, MAP_OUTPUT_COMPRESS_CODEC, MAP_OUTPUT_KEY_CLASS, MAP_OUTPUT_KEY_FIELD_SEPERATOR, MAP_OUTPUT_VALUE_CLASS, MAP_SKIP_INCR_PROC_COUNT, MAP_SKIP_MAX_RECORDS, MAP_SORT_SPILL_PERCENT, MAP_SPECULATIVE, MAPRED_ADMIN_USER_ENV, MAPRED_ADMIN_USER_SHELL, MAPRED_MAP_ADMIN_JAVA_OPTS, MAPRED_REDUCE_ADMIN_JAVA_OPTS, MAPREDUCE_APPLICATION_CLASSPATH, MAPREDUCE_APPLICATION_FRAMEWORK_PATH, MAPREDUCE_JOB_CLASSLOADER, MAPREDUCE_JOB_CLASSLOADER_SYSTEM_CLASSES, MAPREDUCE_JOB_CREDENTIALS_BINARY, MAPREDUCE_JOB_DIR, MAPREDUCE_JOB_SHUFFLE_PROVIDER_SERVICES, MAPREDUCE_JOB_USER_CLASSPATH_FIRST, MAPREDUCE_TASK_CLASSPATH_PRECEDENCE, MAPREDUCE_V2_CHILD_CLASS, MAX_SHUFFLE_FETCH_RETRY_DELAY, MAX_TASK_FAILURES_PER_TRACKER, MR_AM_ADMIN_COMMAND_OPTS, MR_AM_ADMIN_USER_ENV, MR_AM_COMMAND_OPTS, MR_AM_COMMIT_WINDOW_MS, MR_AM_COMMITTER_CANCEL_TIMEOUT_MS, MR_AM_CONTAINERLAUNCHER_THREAD_COUNT_LIMIT, MR_AM_CPU_VCORES, MR_AM_CREATE_JH_INTERMEDIATE_BASE_DIR, MR_AM_ENV, MR_AM_HISTORY_COMPLETE_EVENT_FLUSH_TIMEOUT_MS, MR_AM_HISTORY_JOB_COMPLETE_UNFLUSHED_MULTIPLIER, MR_AM_HISTORY_MAX_UNFLUSHED_COMPLETE_EVENTS, MR_AM_HISTORY_USE_BATCHED_FLUSH_QUEUE_SIZE_THRESHOLD, MR_AM_IGNORE_BLACKLISTING_BLACKLISTED_NODE_PERECENT, MR_AM_JOB_CLIENT_PORT_RANGE, MR_AM_JOB_CLIENT_THREAD_COUNT, MR_AM_JOB_NODE_BLACKLISTING_ENABLE, MR_AM_JOB_RECOVERY_ENABLE, MR_AM_JOB_RECOVERY_ENABLE_DEFAULT, MR_AM_JOB_REDUCE_PREEMPTION_LIMIT, MR_AM_JOB_REDUCE_RAMPUP_UP_LIMIT, MR_AM_JOB_SPECULATOR, MR_AM_LOG_BACKUPS, MR_AM_LOG_KB, MR_AM_LOG_LEVEL, MR_AM_MAX_ATTEMPTS, MR_AM_NUM_PROGRESS_SPLITS, MR_AM_PREFIX, MR_AM_SECURITY_SERVICE_AUTHORIZATION_CLIENT, MR_AM_SECURITY_SERVICE_AUTHORIZATION_TASK_UMBILICAL, MR_AM_STAGING_DIR, MR_AM_TASK_ESTIMATOR, MR_AM_TASK_ESTIMATOR_EXPONENTIAL_RATE_ENABLE, MR_AM_TASK_ESTIMATOR_SMOOTH_LAMBDA_MS, MR_AM_TASK_LISTENER_THREAD_COUNT, MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS, MR_AM_TO_RM_WAIT_INTERVAL_MS, MR_AM_VMEM_MB, MR_APPLICATION_TYPE, MR_CLIENT_MAX_RETRIES, MR_CLIENT_TO_AM_IPC_MAX_RETRIES, MR_CLIENT_TO_AM_IPC_MAX_RETRIES_ON_TIMEOUTS, MR_JOB_END_NOTIFICATION_MAX_ATTEMPTS, MR_JOB_END_NOTIFICATION_MAX_RETRY_INTERVAL, MR_JOB_END_NOTIFICATION_PROXY, MR_JOB_END_NOTIFICATION_TIMEOUT, MR_JOB_END_NOTIFICATION_URL, MR_JOB_END_RETRY_ATTEMPTS, MR_JOB_END_RETRY_INTERVAL, MR_PREFIX, NUM_MAP_PROFILES, NUM_MAPS, NUM_REDUCE_PROFILES, NUM_REDUCES, OUTPUT, OUTPUT_FORMAT_CLASS_ATTR, OUTPUT_KEY_CLASS, OUTPUT_VALUE_CLASS, PARTITIONER_CLASS_ATTR, PRESERVE_FAILED_TASK_FILES, PRESERVE_FILES_PATTERN, PRIORITY, QUEUE_NAME, RECORDS_BEFORE_PROGRESS, REDUCE_CLASS_ATTR, REDUCE_CPU_VCORES, REDUCE_DEBUG_SCRIPT, REDUCE_ENV, REDUCE_FAILURES_MAXPERCENT, REDUCE_INPUT_BUFFER_PERCENT, REDUCE_JAVA_OPTS, REDUCE_LOG_LEVEL, REDUCE_MARKRESET_BUFFER_PERCENT, REDUCE_MARKRESET_BUFFER_SIZE, REDUCE_MAX_ATTEMPTS, REDUCE_MEMORY_MB, REDUCE_MEMORY_TOTAL_BYTES, REDUCE_MEMTOMEM_ENABLED, REDUCE_MEMTOMEM_THRESHOLD, REDUCE_MERGE_INMEM_THRESHOLD, REDUCE_SKIP_INCR_PROC_COUNT, REDUCE_SKIP_MAXGROUPS, REDUCE_SPECULATIVE, SETUP_CLEANUP_NEEDED, SHUFFLE_CONNECT_TIMEOUT, SHUFFLE_FETCH_FAILURES, SHUFFLE_INPUT_BUFFER_PERCENT, SHUFFLE_MEMORY_LIMIT_PERCENT, SHUFFLE_MERGE_PERCENT, SHUFFLE_NOTIFY_READERROR, SHUFFLE_PARALLEL_COPIES, SHUFFLE_READ_TIMEOUT, SKIP_OUTDIR, SKIP_RECORDS, SKIP_START_ATTEMPTS, SPECULATIVE_SLOWNODE_THRESHOLD, SPECULATIVE_SLOWTASK_THRESHOLD, SPECULATIVECAP, SPLIT_FILE, SPLIT_METAINFO_MAXSIZE, STDERR_LOGFILE_ENV, STDOUT_LOGFILE_ENV, TASK_ATTEMPT_ID, TASK_CLEANUP_NEEDED, TASK_DEBUGOUT_LINES, TASK_ID, TASK_ISMAP, TASK_LOG_BACKUPS, TASK_MAP_PROFILE_PARAMS, TASK_OUTPUT_DIR, TASK_PARTITION, TASK_PROFILE, TASK_PROFILE_PARAMS, TASK_REDUCE_PROFILE_PARAMS, TASK_TEMP_DIR, TASK_TIMEOUT, TASK_TIMEOUT_CHECK_INTERVAL_MS, TASK_USERLOG_LIMIT, USER_LOG_RETAIN_HOURS, USER_NAME, WORKDIR, WORKFLOW_ADJACENCY_PREFIX_PATTERN, WORKFLOW_ADJACENCY_PREFIX_STRING, WORKFLOW_ID, WORKFLOW_NAME, WORKFLOW_NODE_NAME, WORKFLOW_TAGS, WORKING_DIR

Constructor Summary

Constructors
Constructor and Description

TableTaskAttemptContext(Configuration jobConf)

Constructors
Constructor and Description
`TableTaskAttemptContext(Configuration jobConf)`

Method Summary

Methods
Modifier and Type	Method and Description
`Path[]`	`getArchiveClassPaths()` Specified by `JobContext` interface (`TaskAttemptContext` extends `JobContext`).
`String[]`	`getArchiveTimestamps()`
`URI[]`	`getCacheArchives()`
`URI[]`	`getCacheFiles()`
`Class<? extends Reducer<?,?,?,?>>`	`getCombinerClass()`
`RawComparator<?>`	`getCombinerKeyGroupingComparator()`
`Configuration`	`getConfiguration()`
`Counter`	`getCounter(Enum<?> counterName)`
`Counter`	`getCounter(String groupName, String counterName)`
`Credentials`	`getCredentials()`
`Path[]`	`getFileClassPaths()`
`String[]`	`getFileTimestamps()`
`RawComparator<?>`	`getGroupingComparator()`
`Class<? extends InputFormat<?,?>>`	`getInputFormatClass()`
`String`	`getJar()`
`JobID`	`getJobID()`
`String`	`getJobName()`
`boolean`	`getJobSetupCleanupNeeded()`
`Path[]`	`getLocalCacheArchives()`
`Path[]`	`getLocalCacheFiles()`
`Class<?>`	`getMapOutputKeyClass()`
`Class<?>`	`getMapOutputValueClass()`
`Class<? extends Mapper<?,?,?,?>>`	`getMapperClass()`
`int`	`getMaxMapAttempts()`
`int`	`getMaxReduceAttempts()`
`int`	`getNumReduceTasks()`
`Class<? extends OutputFormat<?,?>>`	`getOutputFormatClass()`
`Class<?>`	`getOutputKeyClass()`
`Class<?>`	`getOutputValueClass()`
`Class<? extends Partitioner<?,?>>`	`getPartitionerClass()`
`boolean`	`getProfileEnabled()`
`String`	`getProfileParams()`
`Configuration.IntegerRanges`	`getProfileTaskRange(boolean isMap)`
`float`	`getProgress()`
`Class<? extends Reducer<?,?,?,?>>`	`getReducerClass()`
`RawComparator<?>`	`getSortComparator()`
`String`	`getStatus()`
`boolean`	`getSymlink()`
`TaskAttemptID`	`getTaskAttemptID()`
`boolean`	`getTaskCleanupNeeded()`
`String`	`getUser()`
`Path`	`getWorkingDirectory()`
`void`	`progress()` Specified by `Progressable` interface (`TaskAttemptContext` extends `Progressable`).
`void`	`setStatus(String status)`
`boolean`	`userClassesTakesPrecedence()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - TableTaskAttemptContext
```
public TableTaskAttemptContext(Configuration jobConf)
                        throws IOException
```
    Throws:
    
    IOException
- Method Detail
  - getCounter
```
public Counter getCounter(Enum<?> counterName)
```
    Specified by:
    
    getCounter in interface TaskAttemptContext
  - getCounter
```
public Counter getCounter(String groupName,
                 String counterName)
```
    Specified by:
    
    getCounter in interface TaskAttemptContext
  - getProgress
```
public float getProgress()
```
    Specified by:
    
    getProgress in interface TaskAttemptContext
  - getStatus
```
public String getStatus()
```
    Specified by:
    
    getStatus in interface TaskAttemptContext
  - getTaskAttemptID
```
public TaskAttemptID getTaskAttemptID()
```
    Specified by:
    
    getTaskAttemptID in interface TaskAttemptContext
  - setStatus
```
public void setStatus(String status)
```
    Specified by:
    
    setStatus in interface TaskAttemptContext
  - progress
```
public void progress()
```
    Specified by Progressable interface (TaskAttemptContext extends Progressable).
    
    Specified by:
    
    progress in interface Progressable
  - getArchiveClassPaths
```
public Path[] getArchiveClassPaths()
```
    Specified by JobContext interface (TaskAttemptContext extends JobContext). Note that whereas it would be preferrable to define this class to implement TaskAttemptContext and extend the Job class (so that this class inherits the implementations of all of the methods defined below), that cannot be done. This is because the Job class implements the method JobStatus getStatus, while the TaskAttemptContext interface specifies the method String getStatus. As a result, a sub-class of Job cannot implement TaskAttemptContext; because a method implementation that satisfies the getStatus specification in TaskAttemptContext cannot override the implementation of getStatus provided by Job.
    
    Specified by:
    
    getArchiveClassPaths in interface JobContext
  - getArchiveTimestamps
```
public String[] getArchiveTimestamps()
```
    Specified by:
    
    getArchiveTimestamps in interface JobContext
  - getCacheArchives
```
public URI[] getCacheArchives()
                       throws IOException
```
    Specified by:
    
    getCacheArchives in interface JobContext
    
    Throws:
    
    IOException
  - getCacheFiles
```
public URI[] getCacheFiles()
                    throws IOException
```
    Specified by:
    
    getCacheFiles in interface JobContext
    
    Throws:
    
    IOException
  - getCombinerClass
```
public Class<? extends Reducer<?,?,?,?>> getCombinerClass()
                                                   throws ClassNotFoundException
```
    Specified by:
    
    getCombinerClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getCombinerKeyGroupingComparator
```
public RawComparator<?> getCombinerKeyGroupingComparator()
```
    Specified by:
    
    getCombinerKeyGroupingComparator in interface JobContext
  - getConfiguration
```
public Configuration getConfiguration()
```
    Specified by:
    
    getConfiguration in interface JobContext
  - getCredentials
```
public Credentials getCredentials()
```
    Specified by:
    
    getCredentials in interface JobContext
  - getFileClassPaths
```
public Path[] getFileClassPaths()
```
    Specified by:
    
    getFileClassPaths in interface JobContext
  - getFileTimestamps
```
public String[] getFileTimestamps()
```
    Specified by:
    
    getFileTimestamps in interface JobContext
  - getGroupingComparator
```
public RawComparator<?> getGroupingComparator()
```
    Specified by:
    
    getGroupingComparator in interface JobContext
  - getInputFormatClass
```
public Class<? extends InputFormat<?,?>> getInputFormatClass()
                                                      throws ClassNotFoundException
```
    Specified by:
    
    getInputFormatClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getJar
```
public String getJar()
```
    Specified by:
    
    getJar in interface JobContext
  - getJobID
```
public JobID getJobID()
```
    Specified by:
    
    getJobID in interface JobContext
  - getJobName
```
public String getJobName()
```
    Specified by:
    
    getJobName in interface JobContext
  - getJobSetupCleanupNeeded
```
public boolean getJobSetupCleanupNeeded()
```
    Specified by:
    
    getJobSetupCleanupNeeded in interface JobContext
  - getLocalCacheArchives
```
public Path[] getLocalCacheArchives()
                             throws IOException
```
    Specified by:
    
    getLocalCacheArchives in interface JobContext
    
    Throws:
    
    IOException
  - getLocalCacheFiles
```
public Path[] getLocalCacheFiles()
                          throws IOException
```
    Specified by:
    
    getLocalCacheFiles in interface JobContext
    
    Throws:
    
    IOException
  - getMapOutputKeyClass
```
public Class<?> getMapOutputKeyClass()
```
    Specified by:
    
    getMapOutputKeyClass in interface JobContext
  - getMapOutputValueClass
```
public Class<?> getMapOutputValueClass()
```
    Specified by:
    
    getMapOutputValueClass in interface JobContext
  - getMapperClass
```
public Class<? extends Mapper<?,?,?,?>> getMapperClass()
                                                throws ClassNotFoundException
```
    Specified by:
    
    getMapperClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getMaxMapAttempts
```
public int getMaxMapAttempts()
```
    Specified by:
    
    getMaxMapAttempts in interface JobContext
  - getMaxReduceAttempts
```
public int getMaxReduceAttempts()
```
    Specified by:
    
    getMaxReduceAttempts in interface JobContext
  - getNumReduceTasks
```
public int getNumReduceTasks()
```
    Specified by:
    
    getNumReduceTasks in interface JobContext
  - getOutputFormatClass
```
public Class<? extends OutputFormat<?,?>> getOutputFormatClass()
                                                        throws ClassNotFoundException
```
    Specified by:
    
    getOutputFormatClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getOutputKeyClass
```
public Class<?> getOutputKeyClass()
```
    Specified by:
    
    getOutputKeyClass in interface JobContext
  - getOutputValueClass
```
public Class<?> getOutputValueClass()
```
    Specified by:
    
    getOutputValueClass in interface JobContext
  - getPartitionerClass
```
public Class<? extends Partitioner<?,?>> getPartitionerClass()
                                                      throws ClassNotFoundException
```
    Specified by:
    
    getPartitionerClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getProfileEnabled
```
public boolean getProfileEnabled()
```
    Specified by:
    
    getProfileEnabled in interface JobContext
  - getProfileParams
```
public String getProfileParams()
```
    Specified by:
    
    getProfileParams in interface JobContext
  - getProfileTaskRange
```
public Configuration.IntegerRanges getProfileTaskRange(boolean isMap)
```
    Specified by:
    
    getProfileTaskRange in interface JobContext
  - getReducerClass
```
public Class<? extends Reducer<?,?,?,?>> getReducerClass()
                                                  throws ClassNotFoundException
```
    Specified by:
    
    getReducerClass in interface JobContext
    
    Throws:
    
    ClassNotFoundException
  - getSortComparator
```
public RawComparator<?> getSortComparator()
```
    Specified by:
    
    getSortComparator in interface JobContext
  - getSymlink
```
public boolean getSymlink()
```
    Specified by:
    
    getSymlink in interface JobContext
  - getTaskCleanupNeeded
```
public boolean getTaskCleanupNeeded()
```
    Specified by:
    
    getTaskCleanupNeeded in interface JobContext
  - getUser
```
public String getUser()
```
    Specified by:
    
    getUser in interface JobContext
  - getWorkingDirectory
```
public Path getWorkingDirectory()
                         throws IOException
```
    Specified by:
    
    getWorkingDirectory in interface JobContext
    
    Throws:
    
    IOException
  - userClassesTakesPrecedence
```
public boolean userClassesTakesPrecedence()
```
    Specified by:
    
    userClassesTakesPrecedence in interface JobContext

Class TableTaskAttemptContext

Field Summary

Fields inherited from interface org.apache.hadoop.mapreduce.MRJobConfig

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

TableTaskAttemptContext

Method Detail

getCounter

getCounter

getProgress

getStatus

getTaskAttemptID

setStatus

progress

getArchiveClassPaths

getArchiveTimestamps

getCacheArchives

getCacheFiles

getCombinerClass

getCombinerKeyGroupingComparator

getConfiguration

getCredentials

getFileClassPaths

getFileTimestamps

getGroupingComparator

getInputFormatClass

getJar

getJobID

getJobName

getJobSetupCleanupNeeded

getLocalCacheArchives

getLocalCacheFiles

getMapOutputKeyClass

getMapOutputValueClass

getMapperClass

getMaxMapAttempts

getMaxReduceAttempts

getNumReduceTasks

getOutputFormatClass

getOutputKeyClass

getOutputValueClass

getPartitionerClass

getProfileEnabled

getProfileParams

getProfileTaskRange

getReducerClass

getSortComparator

getSymlink

getTaskCleanupNeeded

getUser

getWorkingDirectory

userClassesTakesPrecedence