save

Author: AngersZhuuuu

sql/core/src/main/scala/org/apache/spark/sql/execution/script/ScriptTransformationExec.scala

@@ -149,7 +149,7 @@ private class ScriptTransformationWriterThread(
     stderrBuffer: CircularBuffer,
     taskContext: TaskContext,
     conf: Configuration)
-  extends ScriptTransformationWriterBase(
+  extends ScriptTransformationWriterThreadBase(
       iter,
       inputSchema,
       outputStream,

sql/core/src/main/scala/org/apache/spark/sql/execution/script/ScriptTransformbase.scala

@@ -54,7 +54,7 @@ private[sql] trait ScriptTransformBase extends UnaryExecNode {
 
 
   protected def checkFailureAndPropagate(
-      writerThread: ScriptTransformationWriterBase,
+      writerThread: ScriptTransformationWriterThreadBase,
       cause: Throwable = null,
       proc: Process,
       stderrBuffer: CircularBuffer): Unit = {
@@ -73,7 +73,7 @@ private[sql] trait ScriptTransformBase extends UnaryExecNode {
   }
 }
 
-private[sql] abstract class ScriptTransformationWriterBase(
+private[sql] abstract class ScriptTransformationWriterThreadBase(
     iter: Iterator[InternalRow],
     inputSchema: Seq[DataType],
     outputStream: OutputStream,

sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/script/HiveScriptTransformationExec.scala

@@ -38,7 +38,7 @@ import org.apache.spark.sql.catalyst.expressions._
 import org.apache.spark.sql.catalyst.plans.logical.ScriptInputOutputSchema
 import org.apache.spark.sql.catalyst.plans.physical.Partitioning
 import org.apache.spark.sql.execution._
-import org.apache.spark.sql.execution.script.{ScriptTransformationWriterBase, ScriptTransformBase, ScriptTransformIOSchema}
+import org.apache.spark.sql.execution.script.{ScriptTransformationWriterThreadBase, ScriptTransformBase, ScriptTransformIOSchema}
 import org.apache.spark.sql.hive.HiveInspectors
 import org.apache.spark.sql.hive.HiveShim._
 import org.apache.spark.sql.types.DataType
@@ -225,7 +225,7 @@ private class HiveScriptTransformationWriterThread(
     stderrBuffer: CircularBuffer,
     taskContext: TaskContext,
     conf: Configuration)
-  extends ScriptTransformationWriterBase(
+  extends ScriptTransformationWriterThreadBase(
       iter,
       inputSchema,
       outputStream,