You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/02/11 15:35:41 UTC
[incubator-doris-flink-connector] 31/32: [init] init commit
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 <ch...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org