ec61ba638aa440a93bb977c9a9034b785eb96e62 - seatunnel-web

commit	ec61ba638aa440a93bb977c9a9034b785eb96e62	[log] [tgz]
author	CalvinKirs <kirs@apache.org>	Mon Sep 26 14:50:21 2022 +0800
committer	CalvinKirs <kirs@apache.org>	Mon Sep 26 14:50:21 2022 +0800
tree	8770eb957dc1892a6c96da123f2822eb43487385
parent	d94a874bcb09f476784b6c42cc6ec6468d515023 [diff]

Remove web irrelevant code

.github/PULL_REQUEST_TEMPLATE.md[Deleted - diff]
.github/stale.yml[Deleted - diff]
.github/workflows/backend.yml[Deleted - diff]
.github/workflows/code-analysys.yml[Deleted - diff]
.github/workflows/codeql.yaml[Deleted - diff]
.github/workflows/docker.yml[Deleted - diff]
.github/workflows/documents.yml[Deleted - diff]
.github/workflows/publish-docker.yaml[Deleted - diff]
.scalafmt.conf[Deleted - diff]
DISCLAIMER[Deleted - diff]
LICENSE[Deleted - diff]
NOTICE[Deleted - diff]
README.md[Deleted - diff]
README_zh_CN.md[Deleted - diff]
bin/install-plugin.sh[Deleted - diff]
config/flink.batch.conf.template[Deleted - diff]
config/flink.sql.conf.template[Deleted - diff]
config/flink.streaming.conf.template[Deleted - diff]
config/plugin_config[Deleted - diff]
config/seatunnel-env.sh[Deleted - diff]
config/spark.batch.conf.template[Deleted - diff]
config/spark.streaming.conf.template[Deleted - diff]
deploy/docker/flink/README.md[Deleted - diff]
deploy/docker/flink/config/application.conf[Deleted - diff]
deploy/docker/flink/config/flink-conf.yaml[Deleted - diff]
deploy/docker/flink/docker-compose.yaml[Deleted - diff]
deploy/docker/spark/.env[Deleted - diff]
deploy/docker/spark/README.md[Deleted - diff]
deploy/docker/spark/config/application.conf[Deleted - diff]
deploy/docker/spark/docker-compose.yaml[Deleted - diff]
docs/en/command/usage.mdx[Deleted - diff]
docs/en/concept/config.md[Deleted - diff]
docs/en/concept/connector-v2-features.md[Deleted - diff]
docs/en/connector-v2/sink/Assert.md[Deleted - diff]
docs/en/connector-v2/sink/Clickhouse.md[Deleted - diff]
docs/en/connector-v2/sink/ClickhouseFile.md[Deleted - diff]
docs/en/connector-v2/sink/Console.md[Deleted - diff]
docs/en/connector-v2/sink/Datahub.md[Deleted - diff]
docs/en/connector-v2/sink/Elasticsearch.md[Deleted - diff]
docs/en/connector-v2/sink/Email.md[Deleted - diff]
docs/en/connector-v2/sink/Enterprise-WeChat.md[Deleted - diff]
docs/en/connector-v2/sink/Feishu.md[Deleted - diff]
docs/en/connector-v2/sink/FtpFile.md[Deleted - diff]
docs/en/connector-v2/sink/Greenplum.md[Deleted - diff]
docs/en/connector-v2/sink/HdfsFile.md[Deleted - diff]
docs/en/connector-v2/sink/Hive.md[Deleted - diff]
docs/en/connector-v2/sink/Http.md[Deleted - diff]
docs/en/connector-v2/sink/IoTDB.md[Deleted - diff]
docs/en/connector-v2/sink/Jdbc.md[Deleted - diff]
docs/en/connector-v2/sink/Kudu.md[Deleted - diff]
docs/en/connector-v2/sink/LocalFile.md[Deleted - diff]
docs/en/connector-v2/sink/MongoDB.md[Deleted - diff]
docs/en/connector-v2/sink/Neo4j.md[Deleted - diff]
docs/en/connector-v2/sink/OssFile.md[Deleted - diff]
docs/en/connector-v2/sink/Phoenix.md[Deleted - diff]
docs/en/connector-v2/sink/Redis.md[Deleted - diff]
docs/en/connector-v2/sink/Sentry.md[Deleted - diff]
docs/en/connector-v2/sink/Socket.md[Deleted - diff]
docs/en/connector-v2/sink/common-options.md[Deleted - diff]
docs/en/connector-v2/sink/dingtalk.md[Deleted - diff]
docs/en/connector-v2/source/Clickhouse.md[Deleted - diff]
docs/en/connector-v2/source/FakeSource.md[Deleted - diff]
docs/en/connector-v2/source/FtpFile.md[Deleted - diff]
docs/en/connector-v2/source/Greenplum.md[Deleted - diff]
docs/en/connector-v2/source/HdfsFile.md[Deleted - diff]
docs/en/connector-v2/source/Hive.md[Deleted - diff]
docs/en/connector-v2/source/Http.md[Deleted - diff]
docs/en/connector-v2/source/Hudi.md[Deleted - diff]
docs/en/connector-v2/source/Iceberg.md[Deleted - diff]
docs/en/connector-v2/source/IoTDB.md[Deleted - diff]
docs/en/connector-v2/source/Jdbc.md[Deleted - diff]
docs/en/connector-v2/source/Kudu.md[Deleted - diff]
docs/en/connector-v2/source/LocalFile.md[Deleted - diff]
docs/en/connector-v2/source/MongoDB.md[Deleted - diff]
docs/en/connector-v2/source/OssFile.md[Deleted - diff]
docs/en/connector-v2/source/Phoenix.md[Deleted - diff]
docs/en/connector-v2/source/Redis.md[Deleted - diff]
docs/en/connector-v2/source/Socket.md[Deleted - diff]
docs/en/connector-v2/source/common-options.md[Deleted - diff]
docs/en/connector-v2/source/pulsar.md[Deleted - diff]
docs/en/connector/flink-sql/ElasticSearch.md[Deleted - diff]
docs/en/connector/flink-sql/Jdbc.md[Deleted - diff]
docs/en/connector/flink-sql/Kafka.md[Deleted - diff]
docs/en/connector/flink-sql/usage.md[Deleted - diff]
docs/en/connector/sink/Assert.md[Deleted - diff]
docs/en/connector/sink/Clickhouse.md[Deleted - diff]
docs/en/connector/sink/ClickhouseFile.md[Deleted - diff]
docs/en/connector/sink/Console.mdx[Deleted - diff]
docs/en/connector/sink/Doris.mdx[Deleted - diff]
docs/en/connector/sink/Druid.md[Deleted - diff]
docs/en/connector/sink/Elasticsearch.mdx[Deleted - diff]
docs/en/connector/sink/Email.md[Deleted - diff]
docs/en/connector/sink/File.mdx[Deleted - diff]
docs/en/connector/sink/Hbase.md[Deleted - diff]
docs/en/connector/sink/Hive.md[Deleted - diff]
docs/en/connector/sink/Hudi.md[Deleted - diff]
docs/en/connector/sink/Iceberg.md[Deleted - diff]
docs/en/connector/sink/InfluxDb.md[Deleted - diff]
docs/en/connector/sink/Jdbc.mdx[Deleted - diff]
docs/en/connector/sink/Kafka.md[Deleted - diff]
docs/en/connector/sink/Kudu.md[Deleted - diff]
docs/en/connector/sink/MongoDB.md[Deleted - diff]
docs/en/connector/sink/Phoenix.md[Deleted - diff]
docs/en/connector/sink/Redis.md[Deleted - diff]
docs/en/connector/sink/Tidb.md[Deleted - diff]
docs/en/connector/sink/common-options.md[Deleted - diff]
docs/en/connector/source/Druid.md[Deleted - diff]
docs/en/connector/source/Elasticsearch.md[Deleted - diff]
docs/en/connector/source/Fake.mdx[Deleted - diff]
docs/en/connector/source/FeishuSheet.md[Deleted - diff]
docs/en/connector/source/File.mdx[Deleted - diff]
docs/en/connector/source/Hbase.md[Deleted - diff]
docs/en/connector/source/Hive.md[Deleted - diff]
docs/en/connector/source/Http.md[Deleted - diff]
docs/en/connector/source/Hudi.md[Deleted - diff]
docs/en/connector/source/Iceberg.md[Deleted - diff]
docs/en/connector/source/InfluxDb.md[Deleted - diff]
docs/en/connector/source/Jdbc.mdx[Deleted - diff]
docs/en/connector/source/Kafka.mdx[Deleted - diff]
docs/en/connector/source/Kudu.md[Deleted - diff]
docs/en/connector/source/MongoDB.md[Deleted - diff]
docs/en/connector/source/Phoenix.md[Deleted - diff]
docs/en/connector/source/Redis.md[Deleted - diff]
docs/en/connector/source/Socket.mdx[Deleted - diff]
docs/en/connector/source/Tidb.md[Deleted - diff]
docs/en/connector/source/Webhook.md[Deleted - diff]
docs/en/connector/source/common-options.mdx[Deleted - diff]
docs/en/connector/source/neo4j.md[Deleted - diff]
docs/en/contribution/contribute-plugin.md[Deleted - diff]
docs/en/contribution/new-license.md[Deleted - diff]
docs/en/contribution/setup.md[Deleted - diff]
docs/en/deployment.mdx[Deleted - diff]
docs/en/faq.md[Deleted - diff]
docs/en/images/azkaban.png[Deleted - diff]
docs/en/images/checkstyle.png[Deleted - diff]
docs/en/images/kafka.png[Deleted - diff]
docs/en/images/seatunnel-workflow.svg[Deleted - diff]
docs/en/images/seatunnel_architecture.png[Deleted - diff]
docs/en/images/seatunnel_starter.png[Deleted - diff]
docs/en/images/workflow.png[Deleted - diff]
docs/en/intro/about.md[Deleted - diff]
docs/en/intro/history.md[Deleted - diff]
docs/en/intro/why.md[Deleted - diff]
docs/en/start/docker.md[Deleted - diff]
docs/en/start/kubernetes.mdx[Deleted - diff]
docs/en/start/local.mdx[Deleted - diff]
docs/en/transform/common-options.mdx[Deleted - diff]
docs/en/transform/json.md[Deleted - diff]
docs/en/transform/nullRate.md[Deleted - diff]
docs/en/transform/nulltf.md[Deleted - diff]
docs/en/transform/replace.md[Deleted - diff]
docs/en/transform/split.mdx[Deleted - diff]
docs/en/transform/sql.md[Deleted - diff]
docs/en/transform/udf.md[Deleted - diff]
docs/en/transform/uuid.md[Deleted - diff]
docs/sidebars.js[Deleted - diff]
docs/zh-CN/flink/configuration/sink-plugins/Doris.md[Deleted - diff]
docs/zh-CN/spark/commands/start-seatunnel-spark.sh.md[Deleted - diff]
docs/zh-CN/spark/configuration/ConfigExamples.md[Deleted - diff]
docs/zh-CN/spark/deployment.md[Deleted - diff]
docs/zh-CN/spark/installation.md[Deleted - diff]
docs/zh-CN/spark/quick-start.md[Deleted - diff]
plugin-mapping.properties[Deleted - diff]
plugins/README.md[Deleted - diff]
plugins/json/files/schemas/seatunnel-schema-demo.json[Deleted - diff]
pom.xml[diff]
seatunnel-api/pom.xml[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/common/JobContext.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/common/PluginIdentifierInterface.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/common/PrepareFailException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/common/SeaTunnelPluginLifeCycle.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Option.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/ReadonlyConfig.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/Condition.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/ConfigUtil.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/Expression.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/OptionRule.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/OptionValidationException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/RequiredOption.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/DefaultSerializer.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/DeserializationSchema.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/SerializationSchema.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/Serializer.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/DefaultSinkWriterContext.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SeaTunnelSink.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkAggregatedCommitter.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkCommitter.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkWriter.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Boundedness.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Collector.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SeaTunnelJobAware.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SeaTunnelSource.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SourceEvent.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SourceReader.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SourceSplit.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SourceSplitEnumerator.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SupportCoordinate.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/state/CheckpointListener.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Catalog.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTable.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Column.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TableIdentifier.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TableSchema.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/exception/CatalogException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/exception/DatabaseNotExistException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/exception/TableNotExistException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/DeserializationFormat.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/SerializationFormat.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/SupportReadingMetadata.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/TableSink.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/TableSource.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/CatalogFactory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/DeserializationFormatFactory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/Factory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryException.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/SerializationFormatFactory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/SupportMultipleTable.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableFactoryContext.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableSinkFactory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableSourceFactory.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/ArrayType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/BasicType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/CompositeType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/DecimalType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/LocalTimeType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/MapType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/PrimitiveByteArrayType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/RowKind.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelDataType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java[Deleted - diff]
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SqlType.java[Deleted - diff]
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/OptionTest.java[Deleted - diff]
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/ReadableConfigTest.java[Deleted - diff]
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/util/ConditionTest.java[Deleted - diff]
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/util/ExpressionTest.java[Deleted - diff]
seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/util/OptionRuleTest.java[Deleted - diff]
seatunnel-api/src/test/resources/conf/option-test.conf[Deleted - diff]
seatunnel-apis/pom.xml[Deleted - diff]
seatunnel-apis/seatunnel-api-base/pom.xml[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseTransform.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/Command.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/CommandArgs.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/CommandBuilder.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/env/Execution.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/env/RuntimeEnv.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/plugin/Plugin.java[Deleted - diff]
seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/plugin/PluginClosedException.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/pom.xml[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkTransform.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchTransform.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/enums/FormatType.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamTransform.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/ConfigKeyName.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/SchemaUtil.java[Deleted - diff]
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/pom.xml[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkTransform.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/SparkEnvironment.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchExecution.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingExecution.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingSink.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingSource.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkStructTypeUtil.java[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingExecution.scala[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingSink.scala[Deleted - diff]
seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingSource.scala[Deleted - diff]
seatunnel-common/pom.xml[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/Constants.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/ExceptionUtil.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/Handover.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/PropertiesUtil.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/CheckConfigUtil.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/CheckResult.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/ConfigRuntimeException.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/DeployMode.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/TypesafeConfigUtils.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/constants/CollectionConstants.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/constants/JobMode.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/constants/PluginType.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/JsonUtils.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/ReflectionUtils.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/RetryUtils.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationException.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationUtils.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/StringTemplate.java[Deleted - diff]
seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/VariablesSubstitute.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/config/CheckConfigUtilTest.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/config/CommonTest.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/config/TypesafeConfigUtilsTest.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/ReflectionUtilsTest.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/SerializationUtilsTest.java[Deleted - diff]
seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/VariablesSubstituteTest.java[Deleted - diff]
seatunnel-config/README.md[Deleted - diff]
seatunnel-config/pom.xml[Deleted - diff]
seatunnel-config/seatunnel-config-base/pom.xml[Deleted - diff]
seatunnel-config/seatunnel-config-shade/pom.xml[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/ConfigParseOptions.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigNodePath.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/Path.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/PathParser.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/SimpleConfigObject.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/java/org/apache/seatunnel/config/CompleteTest.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/java/org/apache/seatunnel/config/ConfigFactoryTest.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/java/org/apache/seatunnel/config/JsonFormatTest.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/java/org/apache/seatunnel/config/utils/FileUtils.java[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/resources/factory/config.conf[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/resources/json/spark.batch.conf[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/resources/json/spark.batch.json[Deleted - diff]
seatunnel-config/seatunnel-config-shade/src/test/resources/seatunnel/variables.conf[Deleted - diff]
seatunnel-connectors-v2/README.md[Deleted - diff]
seatunnel-connectors-v2/README.zh.md[Deleted - diff]
seatunnel-connectors-v2/connector-assert/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/excecutor/AssertExecutor.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/rule/AssertFieldRule.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/rule/AssertRuleParser.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/test/java/org/apache/seatunnel/flink/assertion/AssertExecutorTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-assert/src/test/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParserTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseFileCopyMethod.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/Config.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/FileReaderOption.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ReaderOption.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/shard/Shard.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/shard/ShardMetadata.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/DistributedEngine.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseBatchStatement.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseProxy.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ShardRouter.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseTable.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/FileTransfer.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/FileTransferFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ScpFileTransfer.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/ArrayInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/BigDecimalInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/ClickhouseFieldInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DateInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DateTimeInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/FloatInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/IntInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/LongInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/MapInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/StringInjectFunction.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKAggCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/ClickhouseSinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/ClickhouseSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/tool/IntHolder.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseUtil.java[Deleted - diff]
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/TypeConvertUtil.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeaTunnelSchema.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/sink/AbstractSimpleSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/sink/AbstractSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitEnumeratorState.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitReaderContext.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/test/resources/complex.schema.conf[Deleted - diff]
seatunnel-connectors-v2/connector-common/src/test/resources/simple.schema.conf[Deleted - diff]
seatunnel-connectors-v2/connector-console/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-console/src/test/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriterIT.java[Deleted - diff]
seatunnel-connectors-v2/connector-datahub/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DataHubWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-dingtalk/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/BulkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/ElasticsearchVersion.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/BulkResponse.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/IndexInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/BulkElasticsearchException.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/GetElasticsearchVersionException.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/ElasticsearchRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/SeaTunnelRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializerFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/FixedValueIndexSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/VariableIndexSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializerFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/NotIndexTypeSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/RequiredIndexTypeSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchSinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/util/RegexUtils.java[Deleted - diff]
seatunnel-connectors-v2/connector-email/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-email/src/main/java/org/apache/seatunnel/connectors/seatunnel/email/config/EmailSinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-email/src/main/java/org/apache/seatunnel/connectors/seatunnel/email/sink/EmailSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-email/src/main/java/org/apache/seatunnel/connectors/seatunnel/email/sink/EmailSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-email/src/main/resources/fake_to_emailsink_flink.conf[Deleted - diff]
seatunnel-connectors-v2/connector-fake/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeRandomData.java[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/test/java/org.apache.seatunnel.connectors.seatunnel.fake.source/FakeRandomDataTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/test/resources/complex.schema.conf[Deleted - diff]
seatunnel-connectors-v2/connector-fake/src/test/resources/simple.schema.conf[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/BaseHdfsFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/BaseHdfsFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/config/HdfsSourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseSourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/CompressConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/Constant.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/DelimiterConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileFormat.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileSystemType.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/HadoopConf.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/PartitionConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/exception/FilePluginException.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileAggregatedCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileSinkAggregatedCommitter.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileSinkCommitter.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/SaveMode.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/TextFileSinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/state/FileSinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/util/FileSystemUtils.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/OrcWriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/TextWriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/Transaction.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/WriteStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/WriteStrategyFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/BaseFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/BaseFileSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/JsonReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ParquetReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategyFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/state/FileSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/test.orc[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/test.parquet[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConf.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/resources/META-INF/services/org.apache.hadoop.fs.FileSystem[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-hadoop/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/config/LocalConf.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/sink/LocalFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/config/LocalSourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/config/OssConf.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/config/OssConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/sink/OssFileSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source/OssFileSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/resources/META-INF/services/org.apache.hadoop.fs.FileSystem[Deleted - diff]
seatunnel-connectors-v2/connector-file/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-hive/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/HiveConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java[Deleted - diff]
seatunnel-connectors-v2/connector-hive/src/test/resources/fakesource_to_hive.conf[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpResponse.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/DeserializationCollector.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/SimpleTextDeserializationSchema.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-feishu/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-feishu/src/main/java/org/apache/seatunnel/connectors/seatunnel/feishu/sink/FeishuSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-wechat/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatHttpSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/config/WeChatSinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-http/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/config/HudiSourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/exception/HudiPluginException.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/util/HudiUtil.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/SourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/DefaultDeserializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/Deserializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergRecordProjection.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/AbstractSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergBatchSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergEnumerationResult.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergEnumeratorPosition.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergSplitEnumeratorState.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergStreamSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanContext.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergStreamScanStrategy.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergFileScanTaskReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergFileScanTaskSplitReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/split/IcebergFileScanTaskSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-iceberg/src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/TestIcebergMetastore.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/CommonConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/constant/SourceConstants.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/DefaultSeaTunnelRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/IoTDBRecord.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/SeaTunnelRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/state/IoTDBSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/MySqlCatalog.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSinkOptions.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceOptions.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/connection/DataSourceUtils.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/connection/JdbcConnectionProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/connection/SimpleJdbcConnectionProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/JdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbDialect.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbJdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/greenplum/GreenplumDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MysqlDialect.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MysqlJdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixDialect.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixJdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresDialect.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresDialectFactory.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/BiConsumerWithException.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/JdbcBatchStatementExecutor.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/JdbcStatementBuilder.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/SimpleBatchStatementExecutor.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/options/JdbcConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/options/JdbcConnectionOptions.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/options/JdbcConnectorOptions.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcGenericParameterValuesProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcNumericBetweenParametersProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcParameterValuesProvider.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/GroupXaOperationResult.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaFacade.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaFacadeImplAutoLoad.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOps.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOpsImpl.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidGenerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkCommitter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/PartitionParameter.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/state/JdbcAggregatedCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/state/JdbcSinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/state/JdbcSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/state/XidInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ExceptionUtils.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcUtils.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/ThrowingRunnable.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalogTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGeneratorTest.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/Config.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/KafkaSemantics.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize/DefaultSeaTunnelRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize/SeaTunnelRowSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaNoTransactionSender.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaProduceSender.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkCommitter.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaTransactionSender.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/state/KafkaAggregatedCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/state/KafkaCommitInfo.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/state/KafkaSinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/state/KafkaSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSourceConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/kuduclient/KuduInputFormat.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/kuduclient/KuduOutputFormat.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/kuduclient/KuduTypeMapper.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/sink/KuduSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/sink/KuduSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/PartitionParameter.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/state/KuduSourceState.java[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/resources/kudu_to_kudu_flink.conf[Deleted - diff]
seatunnel-connectors-v2/connector-kudu/src/main/resources/kudu_to_kudu_spark.conf[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbParameters.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DataTypeValidator.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DefaultDeserializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/DefaultSerializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/Deserializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/SeaTunnelRowBsonWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/data/Serializer.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/DriverBuilder.java[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-neo4j/src/main/resources/examples/fake_to_neo4j.conf[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/BasePulsarConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarAdminConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarClientConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarConfigUtil.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarConsumerConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/SourceProperties.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumeratorState.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/StartCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/SubscriptionStartCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/TimestampStartCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/stop/LatestMessageStopCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/stop/NeverStopCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/stop/StopCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/stop/TimestampStopCursor.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/discoverer/PulsarDiscoverer.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/discoverer/TopicListDiscoverer.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/discoverer/TopicPatternDiscoverer.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/topic/TopicPartition.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/RecordWithSplitId.java[Deleted - diff]
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/split/PulsarPartitionSplit.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/config/RedisConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/config/RedisDataType.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/config/RedisParameters.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/source/RedisSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/source/RedisSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-sentry/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentryConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentrySink.java[Deleted - diff]
seatunnel-connectors-v2/connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentrySinkState.java[Deleted - diff]
seatunnel-connectors-v2/connector-sentry/src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry/sink/SentrySinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/pom.xml[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/config/SinkConfig.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/sink/SocketClient.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/sink/SocketSink.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/sink/SocketSinkWriter.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSource.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceParameter.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceReader.java[Deleted - diff]
seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/state/SocketState.java[Deleted - diff]
seatunnel-connectors-v2/pom.xml[Deleted - diff]
seatunnel-connectors/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-6/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-elasticsearch-7/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-jdbc/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink-sql/flink-sql-connector-kafka/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink-sql/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/AssertExecutor.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/rule/AssertFieldRule.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParser.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/sink/AssertSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/test/java/org/apache/seatunnel/flink/assertion/AssertExecutorTest.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-assert/src/test/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParserTest.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/ConfigKey.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/ClickhouseFileCopyMethod.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/DistributedEngine.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/IntHolder.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/Shard.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/pojo/ShardMetadata.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseBatchSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileBatchSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ClickhouseBatchStatement.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ClickhouseClient.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/client/ShardRouter.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/ClickhouseTable.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/FileTransfer.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/file/ScpFileTransfer.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/ArrayInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/BigDecimalInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/ClickhouseFieldInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DateInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DateTimeInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/DoubleInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/FloatInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/IntInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/LongInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/main/java/org/apache/seatunnel/flink/clickhouse/sink/inject/StringInjectFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-clickhouse/src/test/java/org/apache/seatunnel/flink/clickhouse/sink/ClickhouseFileTest.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/console/sink/ConsoleSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisSinkFunction.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisStreamLoad.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/sink/DruidOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/sink/DruidSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidInputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidSource.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/druid/source/DruidSql.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/config/Config.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/sink/Elasticsearch6.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch6/src/main/java/org/apache/seatunnel/flink/elasticsearch6/sink/ElasticsearchOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/config/Config.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/sink/Elasticsearch.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch7/src/main/java/org/apache/seatunnel/flink/elasticsearch/sink/ElasticsearchOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/Config.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/FakeSource.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/FakeSourceStream.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/fake/source/MockSchema.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/CsvRowOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/FileSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/sink/JsonRowOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/FileSource.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/JsonRowInputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/file/source/TextRowInputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/java/org/apache/seatunnel/fink/file/source/FileSourceTest.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/JsonFile.text[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/TestFile.text[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.json.conf[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.text.conf[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/Http.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/constant/Settings.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientResult.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/sink/InfluxDbOutputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/sink/InfluxDbSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbInputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbSource.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/influxdb/source/InfluxDbSql.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/Config.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/DefaultTypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/HiveTypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/JdbcInputFormat.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/MysqlTypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/OracleTypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/PostgresTypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/TypeInformationMap.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/sink/JdbcSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/kafka/sink/KafkaSink.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/kafka/source/KafkaTableStream.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/socket/source/SocketStream.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/Clickhouse.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/ClickhouseFile.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/Table.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/FileTransfer.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/RsyncFileTransfer.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/ScpFileTransfer.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/clickhouse/sink/filetransfer/TransferMethod.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/test/resources/sea.conf[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/test/scala/org/apache/seatunnel/spark/clickhouse/sink/ClickhouseFileTest.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/console/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/console/sink/Console.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/Doris.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/doris/sink/DorisUtil.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/sink/Elasticsearch.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/elasticsearch/source/Elasticsearch.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/DataLocator.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/Email.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/ExcelFileSaver.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/email/sink/Util.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/fake/source/Fake.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/fake/source/FakeStream.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/FeishuClient.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-feishu/src/main/scala/org/apache/seatunnel/spark/feishu/source/FeishuSheet.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/sink/File.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/file/source/File.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/sink/Hbase.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/sink/HbaseSaveMode.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/hbase/source/Hbase.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/sink/Hive.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/hive/source/Hive.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/Http.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/constant/Settings.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientResult.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/sink/Hudi.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/sink/Iceberg.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/iceberg/source/Iceberg.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/sink/Jdbc.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/source/Jdbc.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/jdbc/source/util/HiveDialect.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/sink/Kafka.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/sink/KafkaProducerUtil.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/kafka/source/KafkaStream.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/kudu/sink/Kudu.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/kudu/source/Kudu.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/mongodb/sink/MongoDB.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/mongodb/source/MongoDB.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/neo4j/source/Neo4j.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/phoenix/sink/Phoenix.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/phoenix/source/Phoenix.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/Constants.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/RedisDataType.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/RedisUtil.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/common/SelfAchievedRedisProxyConfig.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/source/Redis.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/socket/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/socket/source/SocketStream.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/Config.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/sink/Tidb.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/tidb/source/Tidb.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/HttpData.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/HttpPushServlet.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/JettyServer.scala[Deleted - diff]
seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/src/main/scala/org/apache/seatunnel/spark/webhook/source/WebhookStream.scala[Deleted - diff]
seatunnel-core/README.md[Deleted - diff]
seatunnel-core/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-base/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/Seatunnel.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/Starter.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/AbstractCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/BaseTaskExecuteCommand.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/Command.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/CommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/DeployModeConverter.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/command/NoopParameterSplitter.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/AbstractExecutionContext.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/ConfigBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/ConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/ConfigParser.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/EngineType.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/EnvironmentFactory.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/config/ExecutionFactory.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/constants/Constants.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/exception/CommandException.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/exception/CommandExecuteException.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/exception/ConfigCheckException.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/utils/AsciiArtUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/utils/CommandLineUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/utils/CompressionUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/core/base/utils/FileUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/test/java/org/apache/seatunnel/core/base/command/BaseTaskExecuteCommandTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/test/java/org/apache/seatunnel/core/base/utils/CompressionUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/test/java/org/apache/seatunnel/core/base/utils/FileUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/test/resources/flink.batch.conf[Deleted - diff]
seatunnel-core/seatunnel-core-base/src/test/resources/plugin-mapping.properties[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/README.md[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/bin/start-seatunnel-sql.sh[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParser.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/FlinkSqlStarter.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/SeatunnelSql.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoader.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/JobInfo.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/splitter/SqlStatementSplitter.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/FlinkEnvParameterParserTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/SqlVariableSubstitutionTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/classloader/CustomClassLoaderTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/job/ExecutorTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/job/JobInfoTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/java/org/apache/seatunnel/core/sql/splitter/SqlStatementSplitterTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink-sql/src/test/resources/flink.sql.conf.template[Deleted - diff]
seatunnel-core/seatunnel-core-flink/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/bin/start-seatunnel-flink.sh[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/docker/Dockerfile[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParser.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/FlinkStarter.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/SeatunnelFlink.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/args/FlinkCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiConfValidateCommand.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkCommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkApiConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkExecutionContext.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkJobType.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/config/FlinkRunMode.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/FlinkEnvParameterParserTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/FlinkStarterTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/args/FlinkCommandArgsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommandTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/java/org/apache/seatunnel/core/flink/utils/CommandLineUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/resources/app.conf[Deleted - diff]
seatunnel-core/seatunnel-core-flink/src/test/resources/sql.conf[Deleted - diff]
seatunnel-core/seatunnel-core-spark/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/bin/start-seatunnel-spark.sh[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/docker/Dockerfile[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SeatunnelSpark.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/args/SparkCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkCommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkConfValidateCommand.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/command/SparkTaskExecuteCommand.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/config/SparkApiConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/config/SparkExecutionContext.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/SparkStarterTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/args/SparkCommandArgsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/test/java/org/apache/seatunnel/core/spark/utils/CommandLineUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-spark/src/test/resources/spark_application.conf[Deleted - diff]
seatunnel-core/seatunnel-core-starter/README.md[Deleted - diff]
seatunnel-core/seatunnel-core-starter/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/Seatunnel.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/Starter.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/command/AbstractCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/command/Command.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/command/CommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/command/CommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/command/DeployModeConverter.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/ConfigBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/ConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/EngineType.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/EnvironmentFactory.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/PluginType.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/constants/Constants.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/exception/CommandException.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/exception/CommandExecuteException.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/exception/ConfigCheckException.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/exception/TaskExecuteException.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/execution/TaskExecution.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/AsciiArtUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/CommandLineUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/CompressionUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/FileUtils.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/test/java/org/apache/seatunnel/core/starter/utils/CompressionUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/test/java/org/apache/seatunnel/core/starter/utils/FileUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-core-starter/src/test/resources/flink.batch.conf[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/bin/start-seatunnel-flink-connector-v2.sh[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/docker/Dockerfile[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/SeatunnelFlink.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/args/FlinkCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkApiConfValidateCommand.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkApiTaskExecuteCommand.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkCommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkApiConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkApiEnvironment.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkCommon.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkEnvironmentFactory.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/FlinkRunMode.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/StarterConstant.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/AbstractPluginExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/FlinkExecution.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/PluginExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SinkExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SourceExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/TransformExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/test/java/org/apache/seatunnel/core/starter/flink/FlinkStarterTest.java[Deleted - diff]
seatunnel-core/seatunnel-flink-starter/src/test/java/org/apache/seatunnel/core/starter/flink/args/FlinkCommandArgsTest.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/pom.xml[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/bin/start-seatunnel-spark-connector-v2.sh[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/docker/Dockerfile[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SeatunnelSpark.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/args/SparkCommandArgs.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/command/SparkApiConfValidateCommand.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/command/SparkApiTaskExecuteCommand.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/command/SparkCommandBuilder.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/SparkApiConfigChecker.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/SparkEnvironmentFactory.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/StarterConstant.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/AbstractPluginExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/PluginExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/SinkExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/SourceExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/SparkExecution.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/TransformExecuteProcessor.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/test/java/org/apache/seatunnel/core/starter/spark/SparkStarterTest.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/test/java/org/apache/seatunnel/core/starter/spark/args/SparkCommandArgsTest.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/test/java/org/apache/seatunnel/core/starter/spark/utils/CommandLineUtilsTest.java[Deleted - diff]
seatunnel-core/seatunnel-spark-starter/src/test/resources/spark_application.conf[Deleted - diff]
seatunnel-dist/pom.xml[Deleted - diff]
seatunnel-dist/release-docs/LICENSE[Deleted - diff]
seatunnel-dist/release-docs/NOTICE[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-akka.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-avro.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-connons-math.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-grizzled.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-javassist.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-javax-annootation-api.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-kryo.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-minlog.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-orc.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-parquet-format.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-parquet-mr.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-protobuf.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-reactive.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-scala.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-scopt.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-sjf4j.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-xz.txt[Deleted - diff]
seatunnel-dist/release-docs/licenses/LICENSE-yetus.txt[Deleted - diff]
seatunnel-dist/src/main/assembly/assembly-bin-ci.xml[Deleted - diff]
seatunnel-dist/src/main/assembly/assembly-bin.xml[Deleted - diff]
seatunnel-dist/src/main/assembly/assembly-src.xml[Deleted - diff]
seatunnel-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/src/test/java/org/apache/seatunnel/e2e/connector/assertion/FakeSourceToAssertIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/src/test/resources/assertion/fakesource_to_assert.conf[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-assert-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-it/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-it/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOpsImplIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-it/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/AbstractFlinkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/AbstractSparkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/TestResource.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/TestSuiteBase.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/AbstractTestContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/ContainerExtendedFactory.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/TestContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/TestContainersFactory.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/Flink13Container.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/Spark2Container.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/ContainerTestingExtension.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestCaseInvocationContextProvider.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestContainerExtension.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestContainers.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/TestLoggerExtension.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/util/ContainerUtil.java[Deleted - diff]
seatunnel-e2e/seatunnel-e2e-common/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/assertion/FakeSourceToAssertIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e/src/test/resources/assertion/fakesource_to_assert.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-assert-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-datahub-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-datahub-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/datahub/FakeSourceToDatahubIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-datahub-flink-e2e/src/test/resources/datahub/fakesource_to_datahub.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-datahub-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-fake-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-fake-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/fake/FakeSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-fake-flink-e2e/src/test/resources/fake/fakesource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-fake-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/file/FakeSourceToFileIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_local_json.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_local_parquet.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/file/fakesource_to_local_text.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-file-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-flink-e2e-base/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-flink-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iceberg/IcebergSourceIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/src/test/resources/iceberg/iceberg_source.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iceberg-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iotdb/FakeSourceToIoTDBIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/iotdb/fakesource_to_iotdb.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/FakeSourceToJdbcIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcDmdbIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcMysqlIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcPhoenixIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcPostgresIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/fakesource_to_jdbc.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/init_sql/dm_init.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/init_sql/mysql_init.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_dm_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_greenplum_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_datatype.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel_upper_lower.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_xa.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_phoenix_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel_upper_lower.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_xa.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbcsource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/mongodb/MongodbIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/resources/mongodb/mongodb_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/redis/redis_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/src/test/java/org/apache/seatunnel/e2e/flink/assertion/FakeSourceToAssertIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/src/test/resources/assertion/fakesource_to_assert.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-assert-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/src/test/java/org/apache/seatunnel/e2e/flink/clickhouse/FakeSourceToClickhouseIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/src/test/resources/clickhouse/fakesource_to_clickhouse.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-clickhouse-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-e2e-base/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/src/test/java/org/apache/seatunnel/e2e/flink/fake/FakeSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/src/test/resources/fake/fakesource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-fake-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/src/test/java/org/apache/seatunnel/e2e/flink/file/FakeSourceToFileIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/src/test/resources/file/fakesource_to_file.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-file-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/src/test/java/org/apache/seatunnel/e2e/flink/http/HttpSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/src/test/resources/http/httpsource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-e2e/seatunnel-connector-flink-http-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-e2e-base/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-e2e-base/src/test/java/org/apache/seatunnel/e2e/flink/sql/FlinkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/src/test/java/org/apache/seatunnel/e2e/flink/sql/fake/DatagenToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/src/test/resources/fake/flink.sql.conf[Deleted - diff]
seatunnel-e2e/seatunnel-flink-sql-e2e/setunnel-connector-flink-sql-fake-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-datahub-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-datahub-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/datahub/FakeSourceToDatahubIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-datahub-spark-e2e/src/test/resources/datahub/fakesource_to_datahub.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-datahub-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-fake-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-fake-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/fake/FakeSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-fake-spark-e2e/src/test/resources/fake/fakesource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-fake-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/file/FakeSourceToFileIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/fakesource_to_local_json.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/fakesource_to_local_parquet.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/file/fakesource_to_local_text.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-file-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iceberg/IcebergSourceIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/src/test/resources/iceberg/iceberg_source.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iceberg-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/iotdb/FakeSourceToIoTDBIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/resources/iotdb/fakesource_to_iotdb.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcDmdbIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcMysqlIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcPhoenixIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcPostgresIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/init_sql/dm_init.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/init_sql/mysql_init.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_dm_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_greenplum_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_datatype.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_parallel_upper_lower.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_xa.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_phoenix_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_parallel_upper_lower.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/jdbc/jdbc_postgres_source_and_sink_xa.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/mongodb/MongodbIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/resources/mongodb/fake_to_mongodb.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/resources/mongodb/mongodb_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/resources/redis/redis_source_and_sink.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-spark-e2e-base/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-spark-e2e-base/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-e2e-base/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-e2e-base/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/src/test/java/org/apache/seatunnel/e2e/spark/fake/FakeSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/src/test/resources/fake/fakesource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-fake-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/src/test/java/org/apache/seatunnel/e2e/spark/http/HttpSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/src/test/resources/http/httpsource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-http-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/pom.xml[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/java/org/apache/seatunnel/e2e/spark/jdbc/FakeSourceToJdbcIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/java/org/apache/seatunnel/e2e/spark/jdbc/JdbcSourceToConsoleIT.java[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/resources/jdbc/fakesource_to_jdbc.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/resources/jdbc/jdbcsource_to_console.conf[Deleted - diff]
seatunnel-e2e/seatunnel-spark-e2e/seatunnel-connector-spark-jdbc-e2e/src/test/resources/log4j.properties[Deleted - diff]
seatunnel-examples/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-flink-connector-v2-example/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java[Deleted - diff]
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/examples/fake_to_console.conf[Deleted - diff]
seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/log4j.properties[Deleted - diff]
seatunnel-examples/seatunnel-flink-examples/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java[Deleted - diff]
seatunnel-examples/seatunnel-flink-examples/src/main/resources/examples/fake_to_console.conf[Deleted - diff]
seatunnel-examples/seatunnel-flink-examples/src/main/resources/log4j.properties[Deleted - diff]
seatunnel-examples/seatunnel-flink-sql-examples/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-flink-sql-examples/src/main/java/org/apache/seatunnel/example/flink/LocalSqlExample.java[Deleted - diff]
seatunnel-examples/seatunnel-flink-sql-examples/src/main/resources/examples/flink.sql.conf.template[Deleted - diff]
seatunnel-examples/seatunnel-flink-sql-examples/src/main/resources/log4j.properties[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/README.md[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/img.png[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/java/org/apache/seatunnel/example/spark/v2/ExampleUtils.java[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/java/org/apache/seatunnel/example/spark/v2/SeaTunnelApiExample.java[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/resources/examples/spark.batch.conf[Deleted - diff]
seatunnel-examples/seatunnel-spark-connector-v2-example/src/main/resources/log4j.properties[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/pom.xml[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkToClickHouseExample.java[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/src/main/resources/examples/spark.batch.clickhouse.conf[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/src/main/resources/examples/spark.batch.conf[Deleted - diff]
seatunnel-examples/seatunnel-spark-examples/src/main/resources/log4j.properties[Deleted - diff]
seatunnel-formats/pom.xml[Deleted - diff]
seatunnel-formats/seatunnel-format-json/pom.xml[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonFormatFactory.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonFormatOptions.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonSerializationSchema.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/RowToJsonConverters.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/TimeFormat.java[Deleted - diff]
seatunnel-formats/seatunnel-format-json/src/main/resources/META-INF/services/org.apache.seatunnel.api.table.factory.Factory[Deleted - diff]
seatunnel-plugin-discovery/pom.xml[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/PluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/PluginIdentifier.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/flink/FlinkAbstractPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/flink/FlinkSinkPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/flink/FlinkSourcePluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/flink/FlinkTransformPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/seatunnel/SeaTunnelFlinkTransformPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/seatunnel/SeaTunnelSinkPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/seatunnel/SeaTunnelSourcePluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/seatunnel/SeaTunnelSparkTransformPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/spark/SparkSinkPluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/spark/SparkSourcePluginDiscovery.java[Deleted - diff]
seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/spark/SparkTransformPluginDiscovery.java[Deleted - diff]
seatunnel-transforms/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/JsonConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/src/main/scala/org/apache/seatunnel/spark/transform/NullRate.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-null-rate/src/main/scala/org/apache/seatunnel/spark/transform/NullRateConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-nulltf/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-nulltf/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-nulltf/src/main/scala/org/apache/seatunnel/spark/transform/Nulltf.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-nulltf/src/main/scala/org/apache/seatunnel/spark/transform/NulltfConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-replace/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-replace/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-replace/src/main/scala/org/apache/seatunnel/spark/transform/Replace.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-replace/src/main/scala/org/apache/seatunnel/spark/transform/ReplaceConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-replace/src/test/scala/org/apache/seatunnel/spark/transform/TestReplace.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/SplitConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-uuid/pom.xml[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-uuid/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-uuid/src/main/scala/org/apache/seatunnel/spark/transform/UUID.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-uuid/src/main/scala/org/apache/seatunnel/spark/transform/UUIDConfig.scala[Deleted - diff]
seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-uuid/src/test/scala/org/apache/seatunnel/spark/transform/TestUUID.scala[Deleted - diff]
seatunnel-translation/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/serialization/RowConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/serialization/SerializerConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/sink/SinkAggregatedCommitterConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/sink/SinkCommitterConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/sink/SinkConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/sink/SinkWriterConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/BaseSourceFunction.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/CoordinatedEnumeratorContext.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/CoordinatedReaderContext.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/CoordinatedSource.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelEnumeratorContext.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelReaderContext.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelSource.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/util/ThreadPoolExecutorFactory.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/CommitWrapperSerializer.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkRowConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkSimpleVersionedSerializer.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkWriterStateSerializer.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/KryoTypeInfo.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/serialization/WrappedRow.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/CommitWrapper.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkCommitter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkGlobalCommitter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSink.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSinkWriter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkWriterState.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/source/RowCollector.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelCoordinatedSource.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelParallelSource.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-flink/src/test/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtilsTest.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkDataSourceWriter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkDataWriter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkDataWriterFactory.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkSink.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkSinkInjector.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkStreamWriter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/sink/SparkWriterCommitMessage.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeaTunnelSourceSupport.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeatunnelInputPartitionReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchPartition.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchSourceReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchPartition.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchSourceReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/pom.xml[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/InternalRowCollector.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/ReaderState.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/serialization/InternalRowConverter.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/source/batch/CoordinatedBatchPartitionReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/source/batch/ParallelBatchPartitionReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/source/micro/CoordinatedMicroBatchPartitionReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/source/micro/MicroBatchState.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/source/micro/ParallelMicroBatchPartitionReader.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/utils/InstantConverterUtils.java[Deleted - diff]
seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/common/utils/TypeConverterUtils.java[Deleted - diff]
tools/checkstyle/checkStyle.xml[Deleted - diff]
tools/checkstyle/scalastyle-config.xml[Deleted - diff]
tools/dependencies/checkLicense.sh[Deleted - diff]
tools/dependencies/known-dependencies.txt[Deleted - diff]
tools/dependencies/license.py[Deleted - diff]
tools/documents/sync.sh[Deleted - diff]
tools/sonarcheck/check.sh[Deleted - diff]

1561 files changed

tree: 8770eb957dc1892a6c96da123f2822eb43487385

.github/
.idea/
.mvn/
seatunnel-server/
seatunnel-ui/
.asf.yaml
.dlc.json
.gitignore
.licenserc.yaml
mvnw
mvnw.cmd
pom.xml