[init] init commit

Move spark-doris-connector from incubator-doris@df2c756
apache · Feb 11, 2022 · ce7d4063f7d0a0568962a845226b43714d0b09f0 · ce7d406
1 parent 8558180
commit ce7d4063f7d0a0568962a845226b43714d0b09f0
Showing 58 changed files with 0 additions and 0 deletions.
diff --git a/build.sh → spark-doris-connector/build.sh b/build.sh → spark-doris-connector/build.sh
diff --git a/pom.xml → spark-doris-connector/pom.xml b/pom.xml → spark-doris-connector/pom.xml
diff --git a/...is/spark/CachedDorisStreamLoadClient.java → ...is/spark/CachedDorisStreamLoadClient.java b/...is/spark/CachedDorisStreamLoadClient.java → ...is/spark/CachedDorisStreamLoadClient.java
diff --git a/...g/apache/doris/spark/DorisStreamLoad.java → ...g/apache/doris/spark/DorisStreamLoad.java b/...g/apache/doris/spark/DorisStreamLoad.java → ...g/apache/doris/spark/DorisStreamLoad.java
diff --git a/...he/doris/spark/backend/BackendClient.java → ...he/doris/spark/backend/BackendClient.java b/...he/doris/spark/backend/BackendClient.java → ...he/doris/spark/backend/BackendClient.java
diff --git a/...doris/spark/cfg/ConfigurationOptions.java → ...doris/spark/cfg/ConfigurationOptions.java b/...doris/spark/cfg/ConfigurationOptions.java → ...doris/spark/cfg/ConfigurationOptions.java
diff --git a/...e/doris/spark/cfg/PropertiesSettings.java → ...e/doris/spark/cfg/PropertiesSettings.java b/...e/doris/spark/cfg/PropertiesSettings.java → ...e/doris/spark/cfg/PropertiesSettings.java
diff --git a/.../org/apache/doris/spark/cfg/Settings.java → .../org/apache/doris/spark/cfg/Settings.java b/.../org/apache/doris/spark/cfg/Settings.java → .../org/apache/doris/spark/cfg/Settings.java
diff --git a/...apache/doris/spark/cfg/SparkSettings.java → ...apache/doris/spark/cfg/SparkSettings.java b/...apache/doris/spark/cfg/SparkSettings.java → ...apache/doris/spark/cfg/SparkSettings.java
diff --git a/...k/exception/ConnectedFailedException.java → ...k/exception/ConnectedFailedException.java b/...k/exception/ConnectedFailedException.java → ...k/exception/ConnectedFailedException.java
diff --git a/...doris/spark/exception/DorisException.java → ...doris/spark/exception/DorisException.java b/...doris/spark/exception/DorisException.java → ...doris/spark/exception/DorisException.java
diff --git a/...ark/exception/DorisInternalException.java → ...ark/exception/DorisInternalException.java b/...ark/exception/DorisInternalException.java → ...ark/exception/DorisInternalException.java
diff --git a/...k/exception/IllegalArgumentException.java → ...k/exception/IllegalArgumentException.java b/...k/exception/IllegalArgumentException.java → ...k/exception/IllegalArgumentException.java
diff --git a/...exception/ShouldNeverHappenException.java → ...exception/ShouldNeverHappenException.java b/...exception/ShouldNeverHappenException.java → ...exception/ShouldNeverHappenException.java
diff --git a/.../spark/exception/StreamLoadException.java → .../spark/exception/StreamLoadException.java b/.../spark/exception/StreamLoadException.java → .../spark/exception/StreamLoadException.java
diff --git a/...doris/spark/rest/PartitionDefinition.java → ...doris/spark/rest/PartitionDefinition.java b/...doris/spark/rest/PartitionDefinition.java → ...doris/spark/rest/PartitionDefinition.java
diff --git a/.../apache/doris/spark/rest/RestService.java → .../apache/doris/spark/rest/RestService.java b/.../apache/doris/spark/rest/RestService.java → .../apache/doris/spark/rest/RestService.java
diff --git a/...ache/doris/spark/rest/models/Backend.java → ...ache/doris/spark/rest/models/Backend.java b/...ache/doris/spark/rest/models/Backend.java → ...ache/doris/spark/rest/models/Backend.java
diff --git a/...e/doris/spark/rest/models/BackendRow.java → ...e/doris/spark/rest/models/BackendRow.java b/...e/doris/spark/rest/models/BackendRow.java → ...e/doris/spark/rest/models/BackendRow.java
diff --git a/...he/doris/spark/rest/models/BackendV2.java → ...he/doris/spark/rest/models/BackendV2.java b/...he/doris/spark/rest/models/BackendV2.java → ...he/doris/spark/rest/models/BackendV2.java
diff --git a/...apache/doris/spark/rest/models/Field.java → ...apache/doris/spark/rest/models/Field.java b/...apache/doris/spark/rest/models/Field.java → ...apache/doris/spark/rest/models/Field.java
diff --git a/...he/doris/spark/rest/models/QueryPlan.java → ...he/doris/spark/rest/models/QueryPlan.java b/...he/doris/spark/rest/models/QueryPlan.java → ...he/doris/spark/rest/models/QueryPlan.java
diff --git a/.../doris/spark/rest/models/RespContent.java → .../doris/spark/rest/models/RespContent.java b/.../doris/spark/rest/models/RespContent.java → .../doris/spark/rest/models/RespContent.java
diff --git a/...pache/doris/spark/rest/models/Schema.java → ...pache/doris/spark/rest/models/Schema.java b/...pache/doris/spark/rest/models/Schema.java → ...pache/doris/spark/rest/models/Schema.java
diff --git a/...pache/doris/spark/rest/models/Tablet.java → ...pache/doris/spark/rest/models/Tablet.java b/...pache/doris/spark/rest/models/Tablet.java → ...pache/doris/spark/rest/models/Tablet.java
diff --git a/...he/doris/spark/serialization/Routing.java → ...he/doris/spark/serialization/Routing.java b/...he/doris/spark/serialization/Routing.java → ...he/doris/spark/serialization/Routing.java
diff --git a/...e/doris/spark/serialization/RowBatch.java → ...e/doris/spark/serialization/RowBatch.java b/...e/doris/spark/serialization/RowBatch.java → ...e/doris/spark/serialization/RowBatch.java
diff --git a/...pache/doris/spark/util/ErrorMessages.java → ...pache/doris/spark/util/ErrorMessages.java b/...pache/doris/spark/util/ErrorMessages.java → ...pache/doris/spark/util/ErrorMessages.java
diff --git a/.../org/apache/doris/spark/util/IOUtils.java → .../org/apache/doris/spark/util/IOUtils.java b/.../org/apache/doris/spark/util/IOUtils.java → .../org/apache/doris/spark/util/IOUtils.java
diff --git a/...ache.spark.sql.sources.DataSourceRegister → ...ache.spark.sql.sources.DataSourceRegister b/...ache.spark.sql.sources.DataSourceRegister → ...ache.spark.sql.sources.DataSourceRegister
diff --git a/...cala/org/apache/doris/spark/package.scala → ...cala/org/apache/doris/spark/package.scala b/...cala/org/apache/doris/spark/package.scala → ...cala/org/apache/doris/spark/package.scala
diff --git a/...he/doris/spark/rdd/AbstractDorisRDD.scala → ...he/doris/spark/rdd/AbstractDorisRDD.scala b/...he/doris/spark/rdd/AbstractDorisRDD.scala → ...he/doris/spark/rdd/AbstractDorisRDD.scala
diff --git a/.../spark/rdd/AbstractDorisRDDIterator.scala → .../spark/rdd/AbstractDorisRDDIterator.scala b/.../spark/rdd/AbstractDorisRDDIterator.scala → .../spark/rdd/AbstractDorisRDDIterator.scala
diff --git a/...g/apache/doris/spark/rdd/DorisSpark.scala → ...g/apache/doris/spark/rdd/DorisSpark.scala b/...g/apache/doris/spark/rdd/DorisSpark.scala → ...g/apache/doris/spark/rdd/DorisSpark.scala
diff --git a/...pache/doris/spark/rdd/ScalaDorisRDD.scala → ...pache/doris/spark/rdd/ScalaDorisRDD.scala b/...pache/doris/spark/rdd/ScalaDorisRDD.scala → ...pache/doris/spark/rdd/ScalaDorisRDD.scala
diff --git a/...he/doris/spark/rdd/ScalaValueReader.scala → ...he/doris/spark/rdd/ScalaValueReader.scala b/...he/doris/spark/rdd/ScalaValueReader.scala → ...he/doris/spark/rdd/ScalaValueReader.scala
diff --git a/...pache/doris/spark/sql/DorisRelation.scala → ...pache/doris/spark/sql/DorisRelation.scala b/...pache/doris/spark/sql/DorisRelation.scala → ...pache/doris/spark/sql/DorisRelation.scala
diff --git a/...doris/spark/sql/DorisSourceProvider.scala → ...doris/spark/sql/DorisSourceProvider.scala b/...doris/spark/sql/DorisSourceProvider.scala → ...doris/spark/sql/DorisSourceProvider.scala
diff --git a/...doris/spark/sql/DorisStreamLoadSink.scala → ...doris/spark/sql/DorisStreamLoadSink.scala b/...doris/spark/sql/DorisStreamLoadSink.scala → ...doris/spark/sql/DorisStreamLoadSink.scala
diff --git a/...e/doris/spark/sql/DorisWriterOption.scala → ...e/doris/spark/sql/DorisWriterOption.scala b/...e/doris/spark/sql/DorisWriterOption.scala → ...e/doris/spark/sql/DorisWriterOption.scala
diff --git a/...ris/spark/sql/DorisWriterOptionKeys.scala → ...ris/spark/sql/DorisWriterOptionKeys.scala b/...ris/spark/sql/DorisWriterOptionKeys.scala → ...ris/spark/sql/DorisWriterOptionKeys.scala
diff --git a/...pache/doris/spark/sql/ScalaDorisRow.scala → ...pache/doris/spark/sql/ScalaDorisRow.scala b/...pache/doris/spark/sql/ScalaDorisRow.scala → ...pache/doris/spark/sql/ScalaDorisRow.scala
diff --git a/...he/doris/spark/sql/ScalaDorisRowRDD.scala → ...he/doris/spark/sql/ScalaDorisRowRDD.scala b/...he/doris/spark/sql/ScalaDorisRowRDD.scala → ...he/doris/spark/sql/ScalaDorisRowRDD.scala
diff --git a/.../spark/sql/ScalaDorisRowValueReader.scala → .../spark/sql/ScalaDorisRowValueReader.scala b/.../spark/sql/ScalaDorisRowValueReader.scala → .../spark/sql/ScalaDorisRowValueReader.scala
diff --git a/.../apache/doris/spark/sql/SchemaUtils.scala → .../apache/doris/spark/sql/SchemaUtils.scala b/.../apache/doris/spark/sql/SchemaUtils.scala → .../apache/doris/spark/sql/SchemaUtils.scala
diff --git a/...la/org/apache/doris/spark/sql/Utils.scala → ...la/org/apache/doris/spark/sql/Utils.scala b/...la/org/apache/doris/spark/sql/Utils.scala → ...la/org/apache/doris/spark/sql/Utils.scala
diff --git a/.../thrift/doris/DorisExternalService.thrift → .../thrift/doris/DorisExternalService.thrift b/.../thrift/doris/DorisExternalService.thrift → .../thrift/doris/DorisExternalService.thrift
diff --git a/src/main/thrift/doris/Status.thrift → ...ector/src/main/thrift/doris/Status.thrift b/src/main/thrift/doris/Status.thrift → ...ector/src/main/thrift/doris/Status.thrift
diff --git a/src/main/thrift/doris/Types.thrift → ...nector/src/main/thrift/doris/Types.thrift b/src/main/thrift/doris/Types.thrift → ...nector/src/main/thrift/doris/Types.thrift
diff --git a/...s/spark/rest/TestPartitionDefinition.java → ...s/spark/rest/TestPartitionDefinition.java b/...s/spark/rest/TestPartitionDefinition.java → ...s/spark/rest/TestPartitionDefinition.java
diff --git a/...che/doris/spark/rest/TestRestService.java → ...che/doris/spark/rest/TestRestService.java b/...che/doris/spark/rest/TestRestService.java → ...che/doris/spark/rest/TestRestService.java
diff --git a/...e/doris/spark/rest/models/TestSchema.java → ...e/doris/spark/rest/models/TestSchema.java b/...e/doris/spark/rest/models/TestSchema.java → ...e/doris/spark/rest/models/TestSchema.java
diff --git a/...oris/spark/serialization/TestRouting.java → ...oris/spark/serialization/TestRouting.java b/...oris/spark/serialization/TestRouting.java → ...oris/spark/serialization/TestRouting.java
diff --git a/...ris/spark/serialization/TestRowBatch.java → ...ris/spark/serialization/TestRowBatch.java b/...ris/spark/serialization/TestRowBatch.java → ...ris/spark/serialization/TestRowBatch.java
diff --git a/...oris/spark/sql/ExpectedExceptionTest.java → ...oris/spark/sql/ExpectedExceptionTest.java b/...oris/spark/sql/ExpectedExceptionTest.java → ...oris/spark/sql/ExpectedExceptionTest.java
diff --git a/...che/doris/spark/sql/TestSchemaUtils.scala → ...che/doris/spark/sql/TestSchemaUtils.scala b/...che/doris/spark/sql/TestSchemaUtils.scala → ...che/doris/spark/sql/TestSchemaUtils.scala
diff --git a/.../doris/spark/sql/TestSparkConnector.scala → .../doris/spark/sql/TestSparkConnector.scala b/.../doris/spark/sql/TestSparkConnector.scala → .../doris/spark/sql/TestSparkConnector.scala
diff --git a/...rg/apache/doris/spark/sql/TestUtils.scala → ...rg/apache/doris/spark/sql/TestUtils.scala b/...rg/apache/doris/spark/sql/TestUtils.scala → ...rg/apache/doris/spark/sql/TestUtils.scala