Class SparkHadoopMapRedUtil

Object
org.apache.spark.mapred.SparkHadoopMapRedUtil

public class SparkHadoopMapRedUtil extends Object
  • Constructor Details

    • SparkHadoopMapRedUtil

      public SparkHadoopMapRedUtil()
  • Method Details

    • commitTask

      public static void commitTask(org.apache.hadoop.mapreduce.OutputCommitter committer, org.apache.hadoop.mapreduce.TaskAttemptContext mrTaskContext, int jobId, int splitId)
      Commits a task output. Before committing the task output, we need to know whether some other task attempt might be racing to commit the same output partition. Therefore, coordinate with the driver in order to determine whether this attempt can commit (please see SPARK-4879 for details).

      Output commit coordinator is only used when spark.hadoop.outputCommitCoordination.enabled is set to true (which is the default).

      Parameters:
      committer - (undocumented)
      mrTaskContext - (undocumented)
      jobId - (undocumented)
      splitId - (undocumented)
    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)