This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-doris-flink-connector.git
commit cb1a419a1d26f13c7963be5a3a6ee783bbb5fe7a
Author: morningman <chenmin...@baidu.com>
AuthorDate: Fri Feb 11 22:59:52 2022 +0800
[init] init commit
Move flink-doris-connector from incubator-doris@df2c756
---
build.sh => flink-doris-connector/build.sh | 0
pom.xml => flink-doris-connector/pom.xml | 0
.../src}/main/java/org/apache/doris/flink/backend/BackendClient.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisOptions.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisSink.java | 0
.../src}/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java | 0
.../main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java | 0
.../main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java | 0
.../apache/doris/flink/deserialization/DorisDeserializationSchema.java | 0
.../doris/flink/deserialization/SimpleListDeserializationSchema.java | 0
.../java/org/apache/doris/flink/exception/ConnectedFailedException.java | 0
.../src}/main/java/org/apache/doris/flink/exception/DorisException.java | 0
.../java/org/apache/doris/flink/exception/DorisInternalException.java | 0
.../java/org/apache/doris/flink/exception/IllegalArgumentException.java | 0
.../java/org/apache/doris/flink/exception/ShouldNeverHappenException.java | 0
.../main/java/org/apache/doris/flink/exception/StreamLoadException.java | 0
.../src}/main/java/org/apache/doris/flink/rest/PartitionDefinition.java | 0
.../src}/main/java/org/apache/doris/flink/rest/RestService.java | 0
.../src}/main/java/org/apache/doris/flink/rest/SchemaUtils.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/Backend.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/BackendRow.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/BackendV2.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/Field.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/QueryPlan.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/RespContent.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/Schema.java | 0
.../src}/main/java/org/apache/doris/flink/rest/models/Tablet.java | 0
.../src}/main/java/org/apache/doris/flink/serialization/Routing.java | 0
.../src}/main/java/org/apache/doris/flink/serialization/RowBatch.java | 0
.../main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java | 0
.../main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java | 0
.../main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java | 0
.../main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java | 0
.../main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java | 0
.../src}/main/java/org/apache/doris/flink/table/DorisStreamLoad.java | 0
.../src}/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java | 0
.../src}/main/java/org/apache/doris/flink/util/ErrorMessages.java | 0
.../src}/main/java/org/apache/doris/flink/util/IOUtils.java | 0
.../resources/META-INF/services/org.apache.flink.table.factories.Factory | 0
{src => flink-doris-connector/src}/main/resources/log4j.properties | 0
.../main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala | 0
.../src}/main/thrift/doris/DorisExternalService.thrift | 0
{src => flink-doris-connector/src}/main/thrift/doris/Status.thrift | 0
{src => flink-doris-connector/src}/main/thrift/doris/Types.thrift | 0
.../src}/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java | 0
.../src}/test/java/org/apache/doris/flink/DorisSinkExample.java | 0
.../src}/test/java/org/apache/doris/flink/DorisSourceDataStream.java | 0
.../src}/test/java/org/apache/doris/flink/DorisSourceExample.java | 0
.../src}/test/java/org/apache/doris/flink/DorisSourceSinkExample.java | 0
.../src}/test/java/org/apache/doris/flink/DorisStreamSinkExample.java | 0
.../src}/test/java/org/apache/doris/flink/serialization/TestRowBatch.java | 0
55 files changed, 0 insertions(+), 0 deletions(-)
diff --git a/build.sh b/flink-doris-connector/build.sh
similarity index 100%
rename from build.sh
rename to flink-doris-connector/build.sh
diff --git a/pom.xml b/flink-doris-connector/pom.xml
similarity index 100%
rename from pom.xml
rename to flink-doris-connector/pom.xml
diff --git a/src/main/java/org/apache/doris/flink/backend/BackendClient.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/backend/BackendClient.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
diff --git a/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java
diff --git
a/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java
diff --git
a/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
diff --git a/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
diff --git a/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
diff --git a/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisSink.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
diff --git a/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java
diff --git
a/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
diff --git
a/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
diff --git
a/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
diff --git
a/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java
diff --git
a/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java
diff --git a/src/main/java/org/apache/doris/flink/exception/DorisException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/exception/DorisException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java
diff --git
a/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/exception/DorisInternalException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java
diff --git
a/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java
diff --git
a/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
diff --git
a/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/exception/StreamLoadException.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java
diff --git a/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java
diff --git a/src/main/java/org/apache/doris/flink/rest/RestService.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/RestService.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
diff --git a/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/SchemaUtils.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/Backend.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Backend.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/Backend.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Backend.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/BackendRow.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendRow.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/BackendRow.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendRow.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/BackendV2.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/Field.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/Field.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/RespContent.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/RespContent.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/Schema.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/Schema.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java
diff --git a/src/main/java/org/apache/doris/flink/rest/models/Tablet.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/rest/models/Tablet.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java
diff --git a/src/main/java/org/apache/doris/flink/serialization/Routing.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/serialization/Routing.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java
diff --git a/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/serialization/RowBatch.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java
similarity index 100%
rename from
src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java
diff --git a/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
diff --git
a/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
diff --git a/src/main/java/org/apache/doris/flink/util/ErrorMessages.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/util/ErrorMessages.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java
diff --git a/src/main/java/org/apache/doris/flink/util/IOUtils.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/util/IOUtils.java
similarity index 100%
rename from src/main/java/org/apache/doris/flink/util/IOUtils.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/util/IOUtils.java
diff --git
a/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
b/flink-doris-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
similarity index 100%
rename from
src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
rename to
flink-doris-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
diff --git a/src/main/resources/log4j.properties
b/flink-doris-connector/src/main/resources/log4j.properties
similarity index 100%
rename from src/main/resources/log4j.properties
rename to flink-doris-connector/src/main/resources/log4j.properties
diff --git
a/src/main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala
b/flink-doris-connector/src/main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala
similarity index 100%
rename from
src/main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala
rename to
flink-doris-connector/src/main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala
diff --git a/src/main/thrift/doris/DorisExternalService.thrift
b/flink-doris-connector/src/main/thrift/doris/DorisExternalService.thrift
similarity index 100%
rename from src/main/thrift/doris/DorisExternalService.thrift
rename to
flink-doris-connector/src/main/thrift/doris/DorisExternalService.thrift
diff --git a/src/main/thrift/doris/Status.thrift
b/flink-doris-connector/src/main/thrift/doris/Status.thrift
similarity index 100%
rename from src/main/thrift/doris/Status.thrift
rename to flink-doris-connector/src/main/thrift/doris/Status.thrift
diff --git a/src/main/thrift/doris/Types.thrift
b/flink-doris-connector/src/main/thrift/doris/Types.thrift
similarity index 100%
rename from src/main/thrift/doris/Types.thrift
rename to flink-doris-connector/src/main/thrift/doris/Types.thrift
diff --git a/src/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java
diff --git a/src/test/java/org/apache/doris/flink/DorisSinkExample.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisSinkExample.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java
diff --git a/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisSourceDataStream.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java
diff --git a/src/test/java/org/apache/doris/flink/DorisSourceExample.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisSourceExample.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java
diff --git a/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java
diff --git a/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
diff --git
a/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java
similarity index 100%
rename from src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java
rename to
flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
