org.apache.spark.mapred

Interface SparkHadoopMapRedUtil

All Known Implementing Classes:

SparkHadoopWriter, SparkHiveDynamicPartitionWriterContainer, SparkHiveWriterContainer

public interface SparkHadoopMapRedUtil

Method Summary

Methods

Modifier and Type	Method and Description
Class<?>	firstAvailableClass(String first, String second)
org.apache.hadoop.mapred.JobContext	newJobContext(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.JobID jobId)
org.apache.hadoop.mapred.TaskAttemptContext	newTaskAttemptContext(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.TaskAttemptID attemptId)
org.apache.hadoop.mapred.TaskAttemptID	newTaskAttemptID(String jtIdentifier, int jobId, boolean isMap, int taskId, int attemptId)

Method Detail

newJobContext

org.apache.hadoop.mapred.JobContext newJobContext(org.apache.hadoop.mapred.JobConf conf,
                                                org.apache.hadoop.mapred.JobID jobId)

newTaskAttemptContext

org.apache.hadoop.mapred.TaskAttemptContext newTaskAttemptContext(org.apache.hadoop.mapred.JobConf conf,
                                                                org.apache.hadoop.mapred.TaskAttemptID attemptId)

newTaskAttemptID

org.apache.hadoop.mapred.TaskAttemptID newTaskAttemptID(String jtIdentifier,
                                                      int jobId,
                                                      boolean isMap,
                                                      int taskId,
                                                      int attemptId)

firstAvailableClass

Class<?> firstAvailableClass(String first,
                           String second)