This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new e5d9e20 [improvement](connector) support doris spark sql datasource
for create table statement in spark 3.3 and above (#264)
e5d9e20 is described below
commit e5d9e20fd64ef5bffea84ba03755ce7bcdef2184
Author: gnehil <[email protected]>
AuthorDate: Wed Feb 12 19:16:11 2025 +0800
[improvement](connector) support doris spark sql datasource for create
table statement in spark 3.3 and above (#264)
---
.../main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala | 2 +-
.../main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala | 2 +-
.../main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
b/spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
index c00cd24..beae22b 100644
---
a/spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
+++
b/spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
@@ -22,7 +22,7 @@ import org.apache.doris.spark.config.DorisConfig
import org.apache.spark.sql.connector.catalog.{Identifier, Table}
import org.apache.spark.sql.types.StructType
-class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with Serializable {
+class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with DorisSourceProvider with Serializable {
override def newTableInstance(identifier: Identifier, config: DorisConfig,
schema: Option[StructType]): Table =
new DorisTable(identifier, config, schema)
diff --git
a/spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
b/spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
index c00cd24..beae22b 100644
---
a/spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
+++
b/spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
@@ -22,7 +22,7 @@ import org.apache.doris.spark.config.DorisConfig
import org.apache.spark.sql.connector.catalog.{Identifier, Table}
import org.apache.spark.sql.types.StructType
-class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with Serializable {
+class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with DorisSourceProvider with Serializable {
override def newTableInstance(identifier: Identifier, config: DorisConfig,
schema: Option[StructType]): Table =
new DorisTable(identifier, config, schema)
diff --git
a/spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
b/spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
index c00cd24..beae22b 100644
---
a/spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
+++
b/spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala
@@ -22,7 +22,7 @@ import org.apache.doris.spark.config.DorisConfig
import org.apache.spark.sql.connector.catalog.{Identifier, Table}
import org.apache.spark.sql.types.StructType
-class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with Serializable {
+class DorisDataSource extends DorisTableProviderBase with
DorisSourceRegisterTrait with DorisSourceProvider with Serializable {
override def newTableInstance(identifier: Identifier, config: DorisConfig,
schema: Option[StructType]): Table =
new DorisTable(identifier, config, schema)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
