squash! Add a comment explaining where the code is copied from

gnehil · Mar 28, 2024 · e537fed · e537fed
1 parent b369566
commit e537fed
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/RecordBatchInputStream.java b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/RecordBatchInputStream.java
@@ -26,7 +26,7 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import org.apache.spark.sql.catalyst.InternalRow;
-import org.apache.spark.sql.doris.spark.ArrowWriter;
+import org.apache.spark.sql.execution.arrow.ArrowWriter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/...e/spark/sql/doris/spark/ArrowWriter.scala → ...ark/sql/execution/arrow/ArrowWriter.scala b/...e/spark/sql/doris/spark/ArrowWriter.scala → ...ark/sql/execution/arrow/ArrowWriter.scala
@@ -15,13 +15,14 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.doris.spark
+package org.apache.spark.sql.execution.arrow
 
 import org.apache.arrow.vector._
 import org.apache.arrow.vector.complex._
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.expressions.SpecializedGetters
 import org.apache.spark.sql.types._
+import org.apache.spark.sql.util.ArrowUtils
 
 import scala.collection.JavaConverters._
 

diff --git a/...he/spark/sql/doris/spark/ArrowUtils.scala → ...rg/apache/spark/sql/util/ArrowUtils.scala b/...he/spark/sql/doris/spark/ArrowUtils.scala → ...rg/apache/spark/sql/util/ArrowUtils.scala
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.doris.spark
+package org.apache.spark.sql.util
 
 import org.apache.arrow.memory.RootAllocator
 import org.apache.arrow.vector.complex.MapVector
-import org.apache.arrow.vector.types.{DateUnit, FloatingPointPrecision, TimeUnit}
 import org.apache.arrow.vector.types.pojo.{ArrowType, Field, FieldType, Schema}
+import org.apache.arrow.vector.types.{DateUnit, FloatingPointPrecision, TimeUnit}
 import org.apache.spark.sql.types._
 
 import scala.collection.JavaConverters._