rename SparkHadoopWriterConfig to HadoopWriteConfigUtil

Author: jiangxb1987

core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriterConfig.scala renamed to core/src/main/scala/org/apache/spark/internal/io/HadoopWriteConfigUtil.scala

@@ -37,7 +37,7 @@ import org.apache.spark.util.{SerializableConfiguration, SerializableJobConf, Ut
  * 3. Implementations should have a constructor with exactly one argument:
  *    (conf: SerializableConfiguration) or (conf: SerializableJobConf).
  */
-abstract class SparkHadoopWriterConfig[K, V: ClassTag] extends Serializable {
+abstract class HadoopWriteConfigUtil[K, V: ClassTag] extends Serializable {
 
   // --------------------------------------------------------------------------
   // Create JobContext/TaskAttemptContext

core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriter.scala

@@ -57,7 +57,7 @@ object SparkHadoopWriter extends Logging {
    */
   def write[K, V: ClassTag](
       rdd: RDD[(K, V)],
-      config: SparkHadoopWriterConfig[K, V]): Unit = {
+      config: HadoopWriteConfigUtil[K, V]): Unit = {
     // Extract context and configuration from RDD.
     val sparkContext = rdd.context
     val stageId = rdd.id
@@ -119,7 +119,7 @@ object SparkHadoopWriter extends Logging {
   /** Write a RDD partition out in a single Spark task. */
   private def executeTask[K, V: ClassTag](
       context: TaskContext,
-      config: SparkHadoopWriterConfig[K, V],
+      config: HadoopWriteConfigUtil[K, V],
       jobTrackerId: String,
       sparkStageId: Int,
       sparkPartitionId: Int,
@@ -175,8 +175,8 @@ object SparkHadoopWriter extends Logging {
  * A helper class that reads JobConf from older mapred API, creates output Format/Committer/Writer.
  */
 private[spark]
-class SparkHadoopMapRedWriterConfig[K, V: ClassTag](conf: SerializableJobConf)
-  extends SparkHadoopWriterConfig[K, V] with Logging {
+class HadoopMapRedWriteConfigUtil[K, V: ClassTag](conf: SerializableJobConf)
+  extends HadoopWriteConfigUtil[K, V] with Logging {
 
   private var outputFormat: Class[_ <: OutputFormat[K, V]] = null
   private var writer: RecordWriter[K, V] = null
@@ -308,8 +308,8 @@ class SparkHadoopMapRedWriterConfig[K, V: ClassTag](conf: SerializableJobConf)
  * Format/Committer/Writer.
  */
 private[spark]
-class SparkHadoopMapReduceWriterConfig[K, V: ClassTag](conf: SerializableConfiguration)
-  extends SparkHadoopWriterConfig[K, V] with Logging {
+class HadoopMapReduceWriteConfigUtil[K, V: ClassTag](conf: SerializableConfiguration)
+  extends HadoopWriteConfigUtil[K, V] with Logging {
 
   private var outputFormat: Class[_ <: NewOutputFormat[K, V]] = null
   private var writer: NewRecordWriter[K, V] = null

core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala

@@ -1051,7 +1051,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
    * configured for a Hadoop MapReduce job.
    */
   def saveAsNewAPIHadoopDataset(conf: Configuration): Unit = self.withScope {
-    val config = new SparkHadoopMapReduceWriterConfig[K, V](new SerializableConfiguration(conf))
+    val config = new HadoopMapReduceWriteConfigUtil[K, V](new SerializableConfiguration(conf))
     SparkHadoopWriter.write(
       rdd = self,
       config = config)
@@ -1064,7 +1064,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
    * MapReduce job.
    */
   def saveAsHadoopDataset(conf: JobConf): Unit = self.withScope {
-    val config = new SparkHadoopMapRedWriterConfig[K, V](new SerializableJobConf(conf))
+    val config = new HadoopMapRedWriteConfigUtil[K, V](new SerializableJobConf(conf))
     SparkHadoopWriter.write(
       rdd = self,
       config = config)