This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e93bbb9500 [Doc] Seatunnel Doc Structure Adjustment (#10351)
e93bbb9500 is described below
commit e93bbb9500a665e8ec80e6551eff73e74001e7ee
Author: misi <[email protected]>
AuthorDate: Wed Jan 21 23:12:28 2026 +0800
[Doc] Seatunnel Doc Structure Adjustment (#10351)
Co-authored-by: misi <[email protected]>
---
docs/en/best-practices/cdc-sync.md | 5 -
.../changelog/connector-lance.md | 0
docs/en/connectors/overview.md | 433 ---------------------
docs/en/{connector-v2 => connectors}/sink/Lance.md | 2 +-
docs/en/developer/architecture/module-design.md | 5 -
.../en/developer/architecture/project-structure.md | 5 -
.../developer/connector-development/catalog-api.md | 5 -
.../connector-development/cdc-connector-guide.md | 5 -
.../en/developer/connector-development/overview.md | 5 -
.../en/developer/connector-development/sink-api.md | 5 -
.../developer/connector-development/source-api.md | 5 -
docs/en/developer/contribution-guide.md | 5 -
docs/en/developer/e2e-testing.md | 5 -
docs/en/developer/engine-development.md | 5 -
docs/en/developer/transform-development.md | 5 -
.../concepts/config-encryption-decryption.md | 234 +++++++++++
.../concepts/connector-isolated-dependency.md | 49 +++
.../{ => common-options}/common-options.md | 0
docs/en/transforms/copy.md | 2 +-
docs/en/transforms/data-validator.md | 2 +-
docs/en/transforms/dynamic-compile.md | 2 +-
docs/en/transforms/embedding.md | 2 +-
docs/en/transforms/field-mapper.md | 2 +-
docs/en/transforms/filter-rowkind.md | 2 +-
docs/en/transforms/filter.md | 2 +-
docs/en/transforms/jsonpath.md | 2 +-
docs/en/transforms/llm.md | 2 +-
docs/en/transforms/replace.md | 2 +-
docs/en/transforms/split.md | 2 +-
docs/sidebars.js | 135 +++----
docs/zh/best-practices/cdc-sync.md | 5 -
.../changelog/connector-lance.md | 0
docs/zh/connectors/overview.md | 433 ---------------------
docs/zh/{connector-v2 => connectors}/sink/Lance.md | 2 +-
docs/zh/developer/architecture/module-design.md | 5 -
.../zh/developer/architecture/project-structure.md | 5 -
.../developer/connector-development/catalog-api.md | 5 -
.../connector-development/cdc-connector-guide.md | 5 -
.../zh/developer/connector-development/overview.md | 5 -
.../zh/developer/connector-development/sink-api.md | 5 -
.../developer/connector-development/source-api.md | 5 -
docs/zh/developer/contribution-guide.md | 5 -
docs/zh/developer/e2e-testing.md | 5 -
docs/zh/developer/engine-development.md | 5 -
docs/zh/developer/transform-development.md | 5 -
.../concepts/config-encryption-decryption.md | 235 +++++++++++
.../concepts/connector-isolated-dependency.md | 50 +++
.../{ => common-options}/common-options.md | 0
docs/zh/transforms/copy.md | 2 +-
docs/zh/transforms/data-validator.md | 2 +-
docs/zh/transforms/dynamic-compile.md | 2 +-
docs/zh/transforms/embedding.md | 2 +-
docs/zh/transforms/field-mapper.md | 2 +-
docs/zh/transforms/filter-rowkind.md | 2 +-
docs/zh/transforms/filter.md | 2 +-
docs/zh/transforms/jsonpath.md | 2 +-
docs/zh/transforms/llm.md | 2 +-
docs/zh/transforms/replace.md | 2 +-
docs/zh/transforms/split.md | 2 +-
.../api/file/AllFileSpecificationCheckTest.java | 4 +-
60 files changed, 641 insertions(+), 1100 deletions(-)
diff --git a/docs/en/best-practices/cdc-sync.md
b/docs/en/best-practices/cdc-sync.md
deleted file mode 100644
index 38dfbe1463..0000000000
--- a/docs/en/best-practices/cdc-sync.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: CDC Sync
----
-
-# TODO: Best Practices for CDC Synchronization
diff --git a/docs/en/connector-v2/changelog/connector-lance.md
b/docs/en/connectors/changelog/connector-lance.md
similarity index 100%
rename from docs/en/connector-v2/changelog/connector-lance.md
rename to docs/en/connectors/changelog/connector-lance.md
diff --git a/docs/en/connectors/overview.md b/docs/en/connectors/overview.md
deleted file mode 100644
index c5194c85b6..0000000000
--- a/docs/en/connectors/overview.md
+++ /dev/null
@@ -1,433 +0,0 @@
----
-title: Connectors Overview
----
-
-# SeaTunnel Connectors Capability Overview
-
-SeaTunnel provides a comprehensive set of connectors that enable you to read
from various data sources and write to different data sinks. This document
provides a detailed capability matrix for all available connectors based on the
[Connector V2 Features](../introduction/concepts/connector-v2-features.md).
-
-## Quick Facts
-
-- **Total Source Connectors**: 79
-- **Total Sink Connectors**: 78
-- **Total Connectors**: 157
-- **Supported Engines**: Spark, Flink, SeaTunnel Zeta
-- **Supported Data Types**: Structured, Unstructured, Multimodal
-
-## Feature Definitions
-
-### Source Connector Features
-
-| Feature | Description |
-|---------|-------------|
-| **exactly-once** | Each piece of data is sent downstream only once, with
state snapshots and offsets for reliability |
-| **column projection** | Read only specified columns from data source
efficiently |
-| **batch** | Supports bounded data processing (job stops after completing all
data) |
-| **stream** | Supports unbounded data processing (continuous streaming) |
-| **parallelism** | Supports parallel execution with multiple tasks reading
different splits |
-| **multimodal** | Supports structured and unstructured data (text, video,
images, binary files) |
-| **support user-defined split** | Users can configure custom split rules |
-| **support multiple table read** | Read multiple tables in one SeaTunnel job |
-
-### Sink Connector Features
-
-| Feature | Description |
-|---------|-------------|
-| **exactly-once** | Each piece of data is written to target only once via key
deduplication or XA transactions |
-| **cdc** | Supports change data capture with INSERT/UPDATE/DELETE operations
based on primary key |
-| **support multiple table write** | Write to multiple tables in one SeaTunnel
job with dynamic table identifiers |
-| **multimodal** | Supports structured and unstructured data (text, video,
images, binary files) |
-
-## Source Connectors Capability Matrix
-
-### Database & CDC Connectors
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| **Jdbc** | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| MySQL | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| PostgreSQL | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Oracle | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| SQLServer | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| DB2 | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Kingbase | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Hive | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| HiveJdbc | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Clickhouse | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Doris | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| StarRocks | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Phoenix | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Greenplum | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Redshift | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Vertica | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| **MySQL-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **PostgreSQL-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **Oracle-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **SQLServer-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **TiDB-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **MongoDB-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **Opengauss-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-
-### NoSQL Databases
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| MongoDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Cassandra | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Hbase | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Redis | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Neo4j | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Data Lake & Warehouse
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Iceberg | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Hudi | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Paimon | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Databend | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Maxcompute | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| OceanBase | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-
-### Message Queues
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Kafka | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Pulsar | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Rabbitmq | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| RocketMQ | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| AmazonSqs | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-
-### File Systems
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| LocalFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| HdfsFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| S3File | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| OssFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| OssJindoFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| ObsFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| CosFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| FtpFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| SftpFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-
-### Time Series & Search Engines
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| InfluxDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| IoTDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| IoTDBv2 | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| TDengine | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Elasticsearch | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Easysearch | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Typesense | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Prometheus | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Vector Databases
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Milvus | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Qdrant | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### APIs & Cloud Services
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Http | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Socket | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Github | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Gitlab | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Jira | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Notion | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| GoogleSheets | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| GraphQL | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| AmazonDynamoDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Klaviyo | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Lemlist | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| MyHours | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| OneSignal | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Persistiq | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Web3j | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Special & Test Connectors
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | column
projection | batch | stream | parallelism | multimodal | user-defined split |
multiple table |
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| FakeSource | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Cloudberry | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Kudu | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| OpenMldb | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Tablestore | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-## Sink Connectors Capability Matrix
-
-### Database Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Jdbc** | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ❌ |
-| **MySQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **PostgreSQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **Oracle** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **SQLServer** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **DB2** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **Kingbase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **Hive** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **Phoenix** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-| **Greenplum** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ |
-
-### NoSQL & Graph Databases
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **MongoDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Cassandra** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Hbase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Redis** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Neo4j** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Aerospike** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **AmazonDynamoDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **GoogleFirestore** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **HugeGraph** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Data Warehouse & Analytical Databases
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Clickhouse** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Doris** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **StarRocks** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Redshift** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Snowflake** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Databend** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Vertica** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Druid** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Message Queue Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Kafka** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Pulsar** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Rabbitmq** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **RocketMQ** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **AmazonSqs** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Activemq** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### File System Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **LocalFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **HdfsFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **S3File** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OssFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OssJindoFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **ObsFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **CosFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **FtpFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **SftpFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **ClickhouseFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Data Lake Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Iceberg** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Hudi** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Paimon** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Search & Time Series Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Elasticsearch** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Easysearch** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Typesense** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **InfluxDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **IoTDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **IoTDBv2** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **TDengine** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Prometheus** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Vector Database Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Milvus** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Qdrant** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### API & Cloud Service Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Http** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **GraphQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Socket** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Datahub** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Maxcompute** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### Specialized Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Console** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Assert** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Email** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Slack** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **DingTalk** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Feishu** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Enterprise-WeChat** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Sentry** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **SensorsData** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-
-### Other Sinks
-
-| Connector | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple
table | multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **S3-Redshift** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **SelectDB-Cloud** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Tablestore** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Kudu** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Cloudberry** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Fluss** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OceanBase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-## Feature Support Summary
-
-### Source Connectors Feature Distribution
-
-| Feature | Count | Percentage | Examples |
-|--------|-------|------------|----------|
-| **Engine Support** | | | |
-| All Three Engines | ~65 | 82% | Most database, file, and message queue
connectors |
-| Spark + Flink Only | ~8 | 10% | Some specialized API connectors |
-| Flink + Zeta Only | ~4 | 5% | CDC connectors |
-| **Processing Mode** | | | |
-| Batch Support | ~60 | 76% | Most database and file connectors |
-| Stream Support | ~70 | 89% | Most connectors, especially CDC and messaging |
-| **Reliability** | | | |
-| Exactly-Once | ~45 | 57% | File connectors, JDBC, Kafka |
-| **Performance** | | | |
-| Parallelism | ~55 | 70% | Most database and file connectors |
-| Column Projection | ~25 | 32% | JDBC, File, some specialized connectors |
-| **Advanced Features** | | | |
-| User-Defined Split | ~15 | 19% | CDC, some file connectors |
-| Multiple Table Read | ~25 | 32% | JDBC and some database connectors |
-| Multimodal Support | ~10 | 13% | File and some specialized connectors |
-
-### Sink Connectors Feature Distribution
-
-| Feature | Count | Percentage | Examples |
-|--------|-------|------------|----------|
-| **Engine Support** | | | |
-| All Three Engines | ~70 | 90% | Most database and file connectors |
-| Spark + Flink Only | ~6 | 8% | Some specialized connectors |
-| Flink + Zeta Only | ~2 | 3% | Specialized cases |
-| **Reliability** | | | |
-| Exactly-Once | ~40 | 51% | JDBC, Kafka, File connectors |
-| **Data Capabilities** | | | |
-| CDC Support | ~5 | 6% | Limited to specialized database sinks |
-| Multiple Table Write | ~15 | 19% | JDBC and some database sinks |
-| Multimodal Support | ~10 | 13% | File and specialized connectors |
-
-## Connector Selection Guide
-
-### Use Case-Based Recommendations
-
-#### For High Throughput Batch Processing
-- **Recommended Sources**: Jdbc, File connectors (LocalFile, HdfsFile, S3File)
-- **Recommended Sinks**: Jdbc, File connectors, Data Lake formats (Iceberg,
Hudi)
-- **Key Features**: Batch support, parallelism, column projection
-
-#### For Real-time Stream Processing
-- **Recommended Sources**: CDC connectors, Kafka, File connectors (stream mode)
-- **Recommended Sinks**: Kafka, Jdbc (with transactions), Real-time databases
-- **Key Features**: Stream support, exactly-once, low latency
-
-#### For Exactly-Once Guarantees
-- **Recommended Sources**: File connectors, JDBC, Kafka
-- **Recommended Sinks**: JDBC (XA transactions), Kafka (2PC), File connectors
-- **Key Features**: Exactly-once, transaction support, state management
-
-#### For Multi-Table Operations
-- **Recommended Sources**: JDBC connectors with multi-table support
-- **Recommended Sinks**: JDBC with dynamic table identifiers
-- **Key Features**: Multiple table read/write, placeholder support
-
-#### For Cloud Integration
-- **Recommended Sources**: Native cloud connectors, File connectors with cloud
storage
-- **Recommended Sinks**: Cloud-specific connectors, File connectors
-- **Examples**: S3File, OSSFile, Snowflake, Redshift, MaxCompute
-
-#### For Advanced Analytics
-- **Recommended Sources**: Data lake formats, Analytical databases
-- **Recommended Sinks**: Data lake formats (Iceberg, Hudi, Paimon), OLAP
databases
-- **Examples**: Clickhouse, Doris, StarRocks, Druid
-
-## Engine Compatibility Notes
-
-### SeaTunnel Zeta (Recommended)
-- **Advantages**: Best performance, most features, unified API
-- **Connector Coverage**: ~82% source, ~90% sink
-- **Use Cases**: Production deployments, performance-critical workloads
-
-### Apache Flink
-- **Advantages**: Stream processing excellence, fault tolerance
-- **Connector Coverage**: ~95% source, ~98% sink
-- **Use Cases**: Complex streaming, stateful processing
-
-### Apache Spark
-- **Advantages**: Batch processing, ecosystem integration
-- **Connector Coverage**: ~90% source, ~98% sink
-- **Use Cases**: Large-scale batch processing, ETL workflows
-
-## Data Format Support
-
-| Data Format | Source Support | Sink Support | Primary Connectors |
-|-------------|----------------|---------------|------------------|
-| **JSON** | ✅ Most | ✅ Most | Universal default format |
-| **CSV** | ✅ File | ✅ File | LocalFile, HdfsFile, S3File |
-| **Avro** | ✅ Kafka/File | ✅ Kafka/File | Kafka, File connectors |
-| **Parquet** | ✅ File/Hive | ✅ File/Hive | LocalFile, HdfsFile, Hive |
-| **ORC** | ✅ File/Hive | ✅ File/Hive | LocalFile, HdfsFile, Hive |
-| **Text** | ✅ File/Kafka | ✅ File/Kafka | File connectors, Kafka |
-| **XML** | ✅ File | ✅ File | File connectors |
-| **Protobuf** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Canal-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Debezium-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Maxwell-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **OGG-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-
-## Getting Started
-
-### Quick Setup
-
-1. **Choose Engine**: Select SeaTunnel Zeta for best performance
-2. **Select Connectors**: Use the matrices above to choose appropriate
source/sink
-3. **Install Plugins**: Download required connector JAR files
-4. **Configure Job**: Create configuration based on feature requirements
-5. **Test & Deploy**: Validate configuration and run production jobs
-
-### Best Practices
-
-1. **Feature Matching**: Choose connectors that support your required features
-2. **Engine Selection**: Use SeaTunnel Zeta when possible for maximum
compatibility
-3. **Performance**: Enable parallelism and batch processing where supported
-4. **Reliability**: Prioritize exactly-once support for critical workloads
-5. **Monitoring**: Monitor connector performance and adjust configurations
-
-## Contributing
-
-Want to add new connectors or improve existing ones? Check our:
-- [Contributor Guide](../contributing.md)
-- [Connector Development Guidelines](../development/connector-development.md)
-- [Community Forums](https://github.com/apache/seatunnel/discussions)
-
----
-
-*This matrix represents the current state of SeaTunnel connectors based on
official documentation. For the most up-to-date information, refer to
individual connector documentation pages. Feature availability may vary between
versions.*
\ No newline at end of file
diff --git a/docs/en/connector-v2/sink/Lance.md
b/docs/en/connectors/sink/Lance.md
similarity index 97%
rename from docs/en/connector-v2/sink/Lance.md
rename to docs/en/connectors/sink/Lance.md
index f4f292ce5a..fc8793f836 100644
--- a/docs/en/connector-v2/sink/Lance.md
+++ b/docs/en/connectors/sink/Lance.md
@@ -16,7 +16,7 @@ Sink connector for Lance format. It can support create and
write dataset 、lanc
## Key features
-- [] [exactly-once](../../concept/connector-v2-features.md)
+- [] [exactly-once](../../introduction/concepts/connector-v2-features.md)
## Using Dependency
<dependency>
diff --git a/docs/en/developer/architecture/module-design.md
b/docs/en/developer/architecture/module-design.md
deleted file mode 100644
index 22d7d55be1..0000000000
--- a/docs/en/developer/architecture/module-design.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Module Design
----
-
-# TODO: Describe internal design patterns for connectors, transforms, and
engine.
diff --git a/docs/en/developer/architecture/project-structure.md
b/docs/en/developer/architecture/project-structure.md
deleted file mode 100644
index 663f251eed..0000000000
--- a/docs/en/developer/architecture/project-structure.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Project Structure
----
-
-# TODO: Explain project modules: api, engine, core, connectors, formats, e2e,
etc.
diff --git a/docs/en/developer/connector-development/catalog-api.md
b/docs/en/developer/connector-development/catalog-api.md
deleted file mode 100644
index f959932df5..0000000000
--- a/docs/en/developer/connector-development/catalog-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Catalog API
----
-
-# TODO: Document catalog-related APIs.
diff --git a/docs/en/developer/connector-development/cdc-connector-guide.md
b/docs/en/developer/connector-development/cdc-connector-guide.md
deleted file mode 100644
index 5c713f6690..0000000000
--- a/docs/en/developer/connector-development/cdc-connector-guide.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: CDC Connector Guide
----
-
-# TODO: Best practices for developing CDC connectors.
diff --git a/docs/en/developer/connector-development/overview.md
b/docs/en/developer/connector-development/overview.md
deleted file mode 100644
index 0eb84f30f8..0000000000
--- a/docs/en/developer/connector-development/overview.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Connector Development Overview
----
-
-# TODO: High-level connector development guide (source, sink, configuration,
checkpointing).
diff --git a/docs/en/developer/connector-development/sink-api.md
b/docs/en/developer/connector-development/sink-api.md
deleted file mode 100644
index e2ca31a6cb..0000000000
--- a/docs/en/developer/connector-development/sink-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Sink API
----
-
-# TODO: Document SeaTunnelSink APIs.
diff --git a/docs/en/developer/connector-development/source-api.md
b/docs/en/developer/connector-development/source-api.md
deleted file mode 100644
index 075411b235..0000000000
--- a/docs/en/developer/connector-development/source-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Source API
----
-
-# TODO: Document SeaTunnelSource APIs.
\ No newline at end of file
diff --git a/docs/en/developer/contribution-guide.md
b/docs/en/developer/contribution-guide.md
deleted file mode 100644
index 13ac8e55bd..0000000000
--- a/docs/en/developer/contribution-guide.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Contribution Guide
----
-
-# TODO: Integrate and summarize content from docs/en/contribution/*.
diff --git a/docs/en/developer/e2e-testing.md b/docs/en/developer/e2e-testing.md
deleted file mode 100644
index 471b81603e..0000000000
--- a/docs/en/developer/e2e-testing.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: E2E Testing
----
-
-# TODO: Document e2e testing practices based on the seatunnel-e2e module.
diff --git a/docs/en/developer/engine-development.md
b/docs/en/developer/engine-development.md
deleted file mode 100644
index fc558bd732..0000000000
--- a/docs/en/developer/engine-development.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Engine Development
----
-
-# TODO: Describe internal architecture and development guide for SeaTunnel
Engine.
diff --git a/docs/en/developer/transform-development.md
b/docs/en/developer/transform-development.md
deleted file mode 100644
index 930c3af77b..0000000000
--- a/docs/en/developer/transform-development.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Transform Development
----
-
-# TODO: Describe how to develop custom transforms, aligning with transform-v2.
diff --git a/docs/en/introduction/concepts/config-encryption-decryption.md
b/docs/en/introduction/concepts/config-encryption-decryption.md
new file mode 100644
index 0000000000..b6b021fe8b
--- /dev/null
+++ b/docs/en/introduction/concepts/config-encryption-decryption.md
@@ -0,0 +1,234 @@
+# Config File Encryption And Decryption
+
+## Introduction
+
+In most production environments, sensitive configuration items such as
passwords are required to be encrypted and cannot be stored in plain text,
SeaTunnel provides a convenient one-stop solution for this.
+
+## How to use
+
+SeaTunnel comes with the function of base64 encryption and decryption, but it
is not recommended for production use, it is recommended that users implement
custom encryption and decryption logic. You can refer to this chapter [How to
implement user-defined encryption and decryption](#How to implement
user-defined encryption and decryption) get more details about it.
+
+Base64 encryption support encrypt the following parameters by default:
+- username
+- password
+- auth
+- token
+- access_key
+- secret_key
+
+And users can add custom parameters to `shade.options` for encryption and
decryption.
+
+Next, I'll show how to quickly use SeaTunnel's own `base64` encryption:
+
+1. And new option `shade.identifier` and `shade.options` in env block of
config file, `shade.identifier` indicate what the encryption method that you
want to use, while `shade.options` specifies which parameters should be
encrypted/decrypted. In this example, we should add `shade.identifier = base64`
in config as the following shown:
+
+ ```hocon
+ #
+ # Licensed to the Apache Software Foundation (ASF) under one or more
+ # contributor license agreements. See the NOTICE file distributed with
+ # this work for additional information regarding copyright ownership.
+ # The ASF licenses this file to You under the Apache License, Version 2.0
+ # (the "License"); you may not use this file except in compliance with
+ # the License. You may obtain a copy of the License at
+ #
+ # http://www.apache.org/licenses/LICENSE-2.0
+ #
+ # Unless required by applicable law or agreed to in writing, software
+ # distributed under the License is distributed on an "AS IS" BASIS,
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ # See the License for the specific language governing permissions and
+ # limitations under the License.
+ #
+
+ env {
+ parallelism = 1
+ shade.identifier = "base64"
+ shade.options = ["username", "password", "f1", "config1.f1",
"config2.list"]
+ }
+
+ source {
+ MySQL-CDC {
+ plugin_output = "fake"
+ parallelism = 1
+ server-id = 5656
+ port = 56725
+ hostname = "127.0.0.1"
+ username = "seatunnel"
+ password = "seatunnel_password"
+ database-name = "inventory_vwyw0n"
+ table-name = "products"
+ url = "jdbc:mysql://localhost:56725"
+ f1 = "seatunnel"
+ # custom shade options
+ config1.f1 = "seatunnel"
+ config2.list = ["seatunnel", "seatunnel", "seatunnel"]
+ }
+ }
+
+ transform {
+ }
+
+ sink {
+ # choose stdout output plugin to output data to console
+ Clickhouse {
+ host = "localhost:8123"
+ database = "default"
+ table = "fake_all"
+ username = "seatunnel"
+ password = "seatunnel_password"
+
+ # cdc options
+ primary_key = "id"
+ support_upsert = true
+ }
+ }
+ ```
+2. Using the shell based on different calculate engine to encrypt config file,
in this example we use zeta:
+
+ ```shell
+ ${SEATUNNEL_HOME}/bin/seatunnel.sh --config config/v2.batch.template
--encrypt
+ ```
+
+ Then you can see the encrypted configuration file in the terminal:
+
+ ```log
+ 2023-02-20 17:50:58,319 INFO
org.apache.seatunnel.core.starter.command.ConfEncryptCommand - Encrypt config:
+ {
+ "env" : {
+ "parallelism" : 1,
+ "shade.identifier" : "base64"
+ },
+ "source" : [
+ {
+ "url" : "jdbc:mysql://localhost:56725",
+ "hostname" : "127.0.0.1",
+ "password" : "c2VhdHVubmVsX3Bhc3N3b3Jk",
+ "port" : 56725,
+ "database-name" : "inventory_vwyw0n",
+ "parallelism" : 1,
+ "plugin_output" : "fake",
+ "table-name" : "products",
+ "plugin_name" : "MySQL-CDC",
+ "server-id" : 5656,
+ "username" : "c2VhdHVubmVs",
+ "f1" : "c2VhdHVubmVs",
+ "config1.f1" : "c2VhdHVubmVs",
+ "config2.list" : ["c2VhdHVubmVs","c2VhdHVubmVs","c2VhdHVubmVs"]
+ }
+ ],
+ "transform" : [],
+ "sink" : [
+ {
+ "database" : "default",
+ "password" : "c2VhdHVubmVsX3Bhc3N3b3Jk",
+ "support_upsert" : true,
+ "host" : "localhost:8123",
+ "plugin_name" : "Clickhouse",
+ "primary_key" : "id",
+ "table" : "fake_all",
+ "username" : "c2VhdHVubmVs"
+ }
+ ]
+ }
+ ```
+3. Of course, not only encrypted configuration files are supported, but if the
user wants to see the decrypted configuration file, you can execute this
command:
+
+ ```shell
+ ${SEATUNNEL_HOME}/bin/seatunnel.sh --config config/v2.batch.template
--decrypt
+ ```
+
+## How to implement user-defined encryption and decryption
+
+If you want to customize the encryption method and the configuration of the
encryption, this section will help you to solve the problem.
+
+1. Create a java maven project
+
+2. Add `seatunnel-api` module with the provided scope in dependencies like the
following shown:
+
+ ```xml
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-api</artifactId>
+ <version>${seatunnel.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ ```
+3. Create a new class and implement interface `ConfigShade`, this interface
has the following methods:
+
+ ```java
+ /**
+ * The interface that provides the ability to encrypt and decrypt {@link
+ * org.apache.seatunnel.shade.com.typesafe.config.Config}
+ */
+ public interface ConfigShade {
+
+ /**
+ * The unique identifier of the current interface, used it to select
the correct {@link
+ * ConfigShade}
+ */
+ String getIdentifier();
+
+ /**
+ * Encrypt the content
+ *
+ * @param content The content to encrypt
+ */
+ String encrypt(String content);
+
+ /**
+ * Decrypt the content
+ *
+ * @param content The content to decrypt
+ */
+ String decrypt(String content);
+
+ /** To expand the options that user want to encrypt */
+ default String[] sensitiveOptions() {
+ return new String[0];
+ }
+ }
+ ```
+4. Create a file named `org.apache.seatunnel.api.configuration.ConfigShade` in
`resources/META-INF/services`, the file content should be the fully qualified
class name of the class that you defined in step 3.
+
+5. Package it to jar and add jar to `${SEATUNNEL_HOME}/lib`
+6. Change the option `shade.identifier` to the value that you defined in
`ConfigShade#getIdentifier`of you config file, please enjoy it \^_\^
+
+### How to encrypt and decrypt with customized params
+
+If you want to encrypt and decrypt with customized params, you can follow the
steps below:
+1. Add a configuration named `shade.properties` in the env part of the
configuration file, the value of this configuration is in the form of key-value
pairs (the type of the key must be a string), as shown below:
+
+ ```hocon
+ env {
+ shade.properties = {
+ suffix = "666"
+ }
+ }
+
+ ```
+
+2. Override the `ConfigShade` interface's `open` method, as shown below:
+
+ ```java
+ public static class ConfigShadeWithProps implements ConfigShade {
+
+ private String suffix;
+ private String identifier = "withProps";
+
+ @Override
+ public void open(Map<String, Object> props) {
+ this.suffix = String.valueOf(props.get("suffix"));
+ }
+ }
+ ```
+3. Use the parameters passed in the open method in the encryption and
decryption methods, as shown below:
+
+ ```java
+ public String encrypt(String content) {
+ return content + suffix;
+ }
+
+ public String decrypt(String content) {
+ return content.substring(0, content.length() - suffix.length());
+ }
+ ```
\ No newline at end of file
diff --git a/docs/en/introduction/concepts/connector-isolated-dependency.md
b/docs/en/introduction/concepts/connector-isolated-dependency.md
new file mode 100644
index 0000000000..0be7f4649a
--- /dev/null
+++ b/docs/en/introduction/concepts/connector-isolated-dependency.md
@@ -0,0 +1,49 @@
+# Connector Isolated Dependency Loading Mechanism
+
+SeaTunnel provides an isolated dependency loading mechanism for each
connector, making it easier for users to manage individual dependencies for
different connectors, while avoiding dependency conflicts and improving system
extensibility.
+When loading a connector, SeaTunnel will search for and load the connector's
own dependency jars from the `${SEATUNNEL_HOME}/plugins/connector-xxx`
directory. This ensures that the dependencies required by different connectors
do not interfere with each other, which is helpful for managing a large number
of connectors in complex environments.
+
+## Principle
+
+Each connector needs to place its own dependency jars in a dedicated
subdirectory under `${SEATUNNEL_HOME}/plugins/connector-xxx` (manual creation
required).
+The subdirectory name is specified by the value in the `plugin-mapping` file.
When SeaTunnel starts and loads connectors, it will only load jars from the
corresponding directory, thus achieving dependency isolation.
+
+Currently, the Zeta engine ensures that jars for different connectors in the
same job are loaded separately. The other two engines still load all connector
dependency jars together, so placing different versions of jars for the same
job in Spark/Flink environments may cause dependency conflicts.
+
+## Directory Structure Example
+
+- Use `${SEATUNNEL_HOME}/connectors/plugin-mapping.properties` to get the
folder name for each connector.
+
+For example, for AmazonDynamodb, suppose the following configuration exists in
the `plugin-mapping` file:
+```
+seatunnel.source.AmazonDynamodb = connector-amazondynamodb
+```
+
+The corresponding connector dependency directory is the value
`connector-amazondynamodb`.
+
+The final directory structure is as follows:
+
+```
+SEATUNNEL_HOME/
+ plugins/
+ connector-amazondynamodb/
+ dependency1.jar
+ dependency2.jar
+ connector-xxx/
+ dependencyA.jar
+ dependencyB.jar
+```
+
+## Limitations
+
+- For the Zeta engine, please ensure that the
`${SEATUNNEL_HOME}/plugins/connector-xxx` directory structure is consistent
across all nodes. Each node must contain the same subdirectories and dependency
jars.
+- Any directory or jar that does not start with `connector-` will be treated
as a common dependency directory, and all engines and connectors will load such
jars.
+- In the Zeta engine, you can achieve shared dependencies for all connectors
by placing common jars in the `${SEATUNNEL_HOME}/lib/` directory.
+
+## Verification
+
+- By checking the job logs, you can confirm that each connector only loads its
own dependency jars.
+
+ ```log
+ 2025-08-13T17:55:48.7732601Z [] 2025-08-13 17:55:47,270 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - find connector
jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Jdbc'}:
[file:/tmp/seatunnel/plugins/Jdbc/lib/vertica-jdbc-12.0.3-0.jar,
file:/tmp/seatunnel/connectors/connector-jdbc-2.3.13-SNAPSHOT-2.12.15.jar]
+ ```
diff --git a/docs/en/transforms/common-options.md
b/docs/en/transforms/common-options/common-options.md
similarity index 100%
rename from docs/en/transforms/common-options.md
rename to docs/en/transforms/common-options/common-options.md
diff --git a/docs/en/transforms/copy.md b/docs/en/transforms/copy.md
index eede3f7d07..56da863c0f 100644
--- a/docs/en/transforms/copy.md
+++ b/docs/en/transforms/copy.md
@@ -18,7 +18,7 @@ Specify the field copy relationship between input and output
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Example
diff --git a/docs/en/transforms/data-validator.md
b/docs/en/transforms/data-validator.md
index dc9de28ddc..2d78d8e183 100644
--- a/docs/en/transforms/data-validator.md
+++ b/docs/en/transforms/data-validator.md
@@ -124,7 +124,7 @@ To create a custom UDF function:
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Examples
diff --git a/docs/en/transforms/dynamic-compile.md
b/docs/en/transforms/dynamic-compile.md
index 440b1d5056..113dc173de 100644
--- a/docs/en/transforms/dynamic-compile.md
+++ b/docs/en/transforms/dynamic-compile.md
@@ -26,7 +26,7 @@ If the conversion is too complex, it may affect performance
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
### compile_language [Enum]
diff --git a/docs/en/transforms/embedding.md b/docs/en/transforms/embedding.md
index d113537ee8..27238c99e3 100644
--- a/docs/en/transforms/embedding.md
+++ b/docs/en/transforms/embedding.md
@@ -189,7 +189,7 @@ The `custom_request_body` option supports placeholders:
### common options
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details.
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details.
## Example Configurations
diff --git a/docs/en/transforms/field-mapper.md
b/docs/en/transforms/field-mapper.md
index ad3c3de191..a5d14f7a39 100644
--- a/docs/en/transforms/field-mapper.md
+++ b/docs/en/transforms/field-mapper.md
@@ -18,7 +18,7 @@ Specify the field mapping relationship between input and
output
### common options [config]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details.
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details.
## Example
diff --git a/docs/en/transforms/filter-rowkind.md
b/docs/en/transforms/filter-rowkind.md
index 68aab44b97..80ed8947db 100644
--- a/docs/en/transforms/filter-rowkind.md
+++ b/docs/en/transforms/filter-rowkind.md
@@ -25,7 +25,7 @@ You can only config one of `include_kinds` and
`exclude_kinds`.
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Examples
diff --git a/docs/en/transforms/filter.md b/docs/en/transforms/filter.md
index 748934e621..9f8bdeb105 100644
--- a/docs/en/transforms/filter.md
+++ b/docs/en/transforms/filter.md
@@ -25,7 +25,7 @@ The list of fields that need to be deleted. Fields not in the
list will be kept.
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Example
diff --git a/docs/en/transforms/jsonpath.md b/docs/en/transforms/jsonpath.md
index 4c17f2184f..3a99e247b2 100644
--- a/docs/en/transforms/jsonpath.md
+++ b/docs/en/transforms/jsonpath.md
@@ -15,7 +15,7 @@
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
### row_error_handle_way [Enum]
diff --git a/docs/en/transforms/llm.md b/docs/en/transforms/llm.md
index 0bc137bded..8ebc13d1cf 100644
--- a/docs/en/transforms/llm.md
+++ b/docs/en/transforms/llm.md
@@ -160,7 +160,7 @@ The `custom_request_body` option supports placeholders:
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## tips
The API interface usually has a rate limit, which can be configured with
Seatunnel's speed limit to ensure smooth operation of the task.
diff --git a/docs/en/transforms/replace.md b/docs/en/transforms/replace.md
index ebb15a9c8b..8f5a69b7ae 100644
--- a/docs/en/transforms/replace.md
+++ b/docs/en/transforms/replace.md
@@ -38,7 +38,7 @@ Whether replace the first match string. Only used when
`is_regex = true`.
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Example
diff --git a/docs/en/transforms/split.md b/docs/en/transforms/split.md
index cf4686c7a6..d56cf08cae 100644
--- a/docs/en/transforms/split.md
+++ b/docs/en/transforms/split.md
@@ -28,7 +28,7 @@ The result fields after split
### common options [string]
-Transform plugin common parameters, please refer to [Transform
Plugin](common-options.md) for details
+Transform plugin common parameters, please refer to [Transform
Plugin](common-options/common-options.md) for details
## Example
diff --git a/docs/sidebars.js b/docs/sidebars.js
index bd3e7e7141..47ace67fa0 100644
--- a/docs/sidebars.js
+++ b/docs/sidebars.js
@@ -15,35 +15,10 @@
* limitations under the License.
*/
-/**
- * Creating a sidebar enables you to:
- - create an ordered group of docs
- - render a sidebar for each doc of that group
- - provide next/previous navigation
-
- The sidebars can be generated from the filesystem, or explicitly defined here.
-
- Create as many sidebars as you want.
- */
-
// @ts-check
/** @type {import('@docusaurus/plugin-content-docs').SidebarsConfig} */
const sidebars = {
- // By default, Docusaurus generates a sidebar from the docs folder
structure
- // tutorialSidebar: [{type: 'autogenerated', dirName: '.'}],
-
- // But you can create a sidebar manually
- /*
- tutorialSidebar: [
- {
- type: 'category',
- label: 'Tutorial',
- items: ['hello'],
- },
- ],
- */
-
"docs": [
{
"type": "category",
@@ -56,7 +31,9 @@ const sidebars = {
"label": "Concepts",
"items": [
"introduction/concepts/config",
+ "introduction/concepts/config-encryption-decryption",
"introduction/concepts/connector-v2-features",
+ "introduction/concepts/connector-isolated-dependency",
"introduction/concepts/schema-feature",
"introduction/concepts/JobEnvConfig",
"introduction/concepts/sink-options-placeholders",
@@ -78,30 +55,25 @@ const sidebars = {
"type": "category",
"label": "Locally",
"items": [
- {
- "type": "autogenerated",
- "dirName": "getting-started/locally"
- }
+ "getting-started/locally/deployment",
+ "getting-started/locally/quick-start-seatunnel-engine",
+ "getting-started/locally/quick-start-flink",
+ "getting-started/locally/quick-start-spark"
]
},
{
"type": "category",
"label": "Docker",
"items": [
- {
- "type": "autogenerated",
- "dirName": "getting-started/docker"
- }
+ "getting-started/docker/docker"
]
},
{
"type": "category",
"label": "Kubernetes",
"items": [
- {
- "type": "autogenerated",
- "dirName": "getting-started/kubernetes"
- }
+ "getting-started/kubernetes/kubernetes",
+ "getting-started/kubernetes/helm"
]
}
]
@@ -110,14 +82,13 @@ const sidebars = {
"type": "category",
"label": "Connectors",
"items": [
- "connectors/overview",
{
"type": "category",
"label": "Source",
"link": {
"type": "generated-index",
"title": "Source Connectors",
- "description": "List all source connectors supported
by Apache SeaTunnel for now.",
+ "description": "List all source connectors supported
by Apache SeaTunnel.",
"slug": "/connectors/source",
"keywords": ["source"],
"image": "/img/favicon.ico"
@@ -135,7 +106,7 @@ const sidebars = {
"link": {
"type": "generated-index",
"title": "Sink Connectors",
- "description": "List all sink connectors supported by
Apache SeaTunnel for now.",
+ "description": "List all sink connectors supported by
Apache SeaTunnel.",
"slug": "/connectors/sink",
"keywords": ["sink"],
"image": "/img/favicon.ico"
@@ -153,7 +124,7 @@ const sidebars = {
"link": {
"type": "generated-index",
"title": "Formats",
- "description": "List some special formats (not all)
supported by Apache SeaTunnel for now.",
+ "description": "List some special formats supported by
Apache SeaTunnel.",
"slug": "/connectors/formats",
"keywords": ["formats"],
"image": "/img/favicon.ico"
@@ -198,18 +169,43 @@ const sidebars = {
"label": "Transforms",
"link": {
"type": "generated-index",
- "title": "Transforms of SeaTunnel",
- "description": "List all transforms supported by Apache
SeaTunnel for now.",
+ "title": "Transforms",
+ "description": "List all transforms supported by Apache
SeaTunnel.",
"slug": "/transforms",
"keywords": ["transforms"],
"image": "/img/favicon.ico"
},
"items": [
- "transforms/common-options",
- {
- "type": "autogenerated",
- "dirName": "transforms"
- }
+ {
+ "type": "category",
+ "label": "Common Options",
+ "items": [
+ "transforms/common-options/common-options"
+ ]
+ },
+ "transforms/copy",
+ "transforms/data-validator",
+ "transforms/define-sink-type",
+ "transforms/dynamic-compile",
+ "transforms/embedding",
+ "transforms/field-mapper",
+ "transforms/field-rename",
+ "transforms/filter",
+ "transforms/filter-rowkind",
+ "transforms/jsonpath",
+ "transforms/llm",
+ "transforms/metadata",
+ "transforms/regexextract",
+ "transforms/replace",
+ "transforms/rowkind-extractor",
+ "transforms/split",
+ "transforms/sql",
+ "transforms/sql-functions",
+ "transforms/sql-udf",
+ "transforms/table-filter",
+ "transforms/table-merge",
+ "transforms/table-rename",
+ "transforms/transform-multi-table"
]
},
{
@@ -219,7 +215,7 @@ const sidebars = {
"engines/overview",
{
"type": "category",
- "label": "Zeta Engine",
+ "label": "SeaTunnel Engine (Zeta)",
"items": [
"engines/zeta/about",
{
@@ -239,7 +235,7 @@ const sidebars = {
"engines/zeta/resource-isolation",
{
"type": "category",
- "label": "RESTFul API",
+ "label": "REST API",
"items": [
"engines/zeta/rest-api-v1",
"engines/zeta/rest-api-v2",
@@ -258,45 +254,8 @@ const sidebars = {
"engines/spark"
]
},
- {
- "type": "category",
- "label": "Best Practices",
- "items": [
- "best-practices/cdc-sync"
- ]
- },
- {
- "type": "category",
- "label": "Developer Guide",
- "items": [
- {
- "type": "category",
- "label": "Architecture",
- "items": [
- {
- "type": "autogenerated",
- "dirName": "developer/architecture"
- }
- ]
- },
- {
- "type": "category",
- "label": "Connector Development",
- "items": [
- {
- "type": "autogenerated",
- "dirName": "developer/connector-development"
- }
- ]
- },
- "developer/contribution-guide",
- "developer/e2e-testing",
- "developer/engine-development",
- "developer/transform-development"
- ]
- },
"faq"
]
};
-module.exports = sidebars
+module.exports = sidebars;
diff --git a/docs/zh/best-practices/cdc-sync.md
b/docs/zh/best-practices/cdc-sync.md
deleted file mode 100644
index 0ae9d51c5e..0000000000
--- a/docs/zh/best-practices/cdc-sync.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: CDC同步场景
----
-
-# 待办: CDC同步场景最佳实践
diff --git a/docs/zh/connector-v2/changelog/connector-lance.md
b/docs/zh/connectors/changelog/connector-lance.md
similarity index 100%
rename from docs/zh/connector-v2/changelog/connector-lance.md
rename to docs/zh/connectors/changelog/connector-lance.md
diff --git a/docs/zh/connectors/overview.md b/docs/zh/connectors/overview.md
deleted file mode 100644
index 463acca659..0000000000
--- a/docs/zh/connectors/overview.md
+++ /dev/null
@@ -1,433 +0,0 @@
----
-title: 连接器概览
----
-
-# SeaTunnel 连接器能力概览
-
-SeaTunnel 提供了一套全面的连接器，使您能够从各种数据源读取数据并写入不同的数据目标。本文档基于[连接器 V2
特性](../introduction/concepts/connector-v2-features.md)提供了所有可用连接器的详细能力矩阵。
-
-## 快速概览
-
-- **源连接器总数**: 79
-- **目标连接器总数**: 78
-- **连接器总数**: 157
-- **支持的引擎**: Spark、Flink、SeaTunnel Zeta
-- **支持的数据类型**: 结构化、非结构化、多模态
-
-## 特性定义
-
-### 源连接器特性
-
-| 特性 | 描述 |
-|---------|-------------|
-| **exactly-once** | 每条数据只向下游发送一次，通过状态快照和偏移量保证可靠性 |
-| **column projection** | 高效地从数据源只读取指定列 |
-| **batch** | 支持有界数据处理（完成后作业停止） |
-| **stream** | 支持无界数据处理（连续流式处理） |
-| **parallelism** | 支持多个任务并行执行，读取不同的分片 |
-| **multimodal** | 支持结构化和非结构化数据（文本、视频、图片、二进制文件） |
-| **support user-defined split** | 用户可以配置自定义分片规则 |
-| **support multiple table read** | 在一个 SeaTunnel 作业中读取多个表 |
-
-### 目标连接器特性
-
-| 特性 | 描述 |
-|---------|-------------|
-| **exactly-once** | 通过键去重或 XA 事务确保每条数据只写入目标一次 |
-| **cdc** | 支持基于主键的变更数据捕获（INSERT/UPDATE/DELETE 操作） |
-| **support multiple table write** | 在一个 SeaTunnel 作业中写入多个表，使用动态表标识符 |
-| **multimodal** | 支持结构化和非结构化数据（文本、视频、图片、二进制文件） |
-
-## 源连接器能力矩阵
-
-### 数据库和 CDC 连接器
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| **Jdbc** | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| MySQL | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| PostgreSQL | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Oracle | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| SQLServer | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| DB2 | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Kingbase | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Hive | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| HiveJdbc | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Clickhouse | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Doris | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| StarRocks | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Phoenix | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Greenplum | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Redshift | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Vertica | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| **MySQL-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **PostgreSQL-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **Oracle-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **SQLServer-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **TiDB-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **MongoDB-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| **Opengauss-CDC** | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-
-### NoSQL 数据库
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| MongoDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Cassandra | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Hbase | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Redis | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Neo4j | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 数据湖和仓库
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Iceberg | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Hudi | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Paimon | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Databend | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Maxcompute | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| OceanBase | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-
-### 消息队列
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Kafka | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Pulsar | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| Rabbitmq | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| RocketMQ | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-| AmazonSqs | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ✅ |
-
-### 文件系统
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| LocalFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| HdfsFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| S3File | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| OssFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| OssJindoFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| ObsFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| CosFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
-| FtpFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ |
-| SftpFile | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ |
-
-### 时间序列和搜索引擎
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| InfluxDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| IoTDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| IoTDBv2 | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| TDengine | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Elasticsearch | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Easysearch | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Typesense | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Prometheus | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 向量数据库
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Milvus | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Qdrant | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### API 和云服务
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| Http | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Socket | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Github | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Gitlab | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Jira | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Notion | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| GoogleSheets | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| GraphQL | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| AmazonDynamoDB | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Klaviyo | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Lemlist | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| MyHours | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| OneSignal | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Persistiq | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Web3j | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 特殊和测试连接器
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | column projection |
batch | stream | parallelism | multimodal | user-defined split | multiple table
|
-|-----------|-------|-------|----------------|--------------|------------------|-------|--------|-------------|------------|------------------|-----------------|
-| FakeSource | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Cloudberry | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Kudu | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| OpenMldb | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| Tablestore | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-## 目标连接器能力矩阵
-
-### 数据库目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Jdbc** | ✅ | ✅ | ✅ | ✅ | ❌ | ✅ | ❌ |
-| **MySQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **PostgreSQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Oracle** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **SQLServer** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **DB2** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Kingbase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Hive** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Phoenix** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Greenplum** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-
-### NoSQL 和图数据库
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **MongoDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Cassandra** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Hbase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Redis** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Neo4j** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Aerospike** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **AmazonDynamoDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **GoogleFirestore** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **HugeGraph** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 数据仓库和分析型数据库
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Clickhouse** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Doris** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **StarRocks** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Redshift** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Snowflake** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Databend** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Vertica** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Druid** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 消息队列目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Kafka** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Pulsar** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Rabbitmq** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **RocketMQ** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **AmazonSqs** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Activemq** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 文件系统目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **LocalFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **HdfsFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **S3File** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OssFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OssJindoFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **ObsFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **CosFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **FtpFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **SftpFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **ClickhouseFile** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 数据湖目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Iceberg** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Hudi** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Paimon** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 搜索和时间序列目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Elasticsearch** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Easysearch** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Typesense** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **InfluxDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **IoTDB** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **IoTDBv2** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **TDengine** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Prometheus** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 向量数据库目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Milvus** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Qdrant** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### API 和云服务目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Http** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **GraphQL** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Socket** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Datahub** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Maxcompute** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-### 专业化目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **Console** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Assert** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Email** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Slack** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **DingTalk** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Feishu** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Enterprise-WeChat** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **Sentry** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-| **SensorsData** | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ | ❌ |
-
-### 其他目标
-
-| 连接器 | Spark | Flink | SeaTunnel Zeta | exactly-once | cdc | multiple table |
multimodal |
-|-----------|-------|-------|----------------|--------------|-----|----------------|------------|
-| **S3-Redshift** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **SelectDB-Cloud** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Tablestore** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Kudu** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Cloudberry** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **Fluss** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-| **OceanBase** | ✅ | ✅ | ✅ | ✅ | ❌ | ❌ | ❌ |
-
-## 特性支持总结
-
-### 源连接器特性分布
-
-| 特性 | 数量 | 百分比 | 示例 |
-|--------|-------|------------|----------|
-| **引擎支持** | | | |
-| 三引擎全支持 | ~65 | 82% | 大多数数据库、文件和消息队列连接器 |
-| 仅 Spark + Flink | ~8 | 10% | 一些专业化 API 连接器 |
-| 仅 Flink + Zeta | ~4 | 5% | CDC 连接器 |
-| **处理模式** | | | |
-| 批处理支持 | ~60 | 76% | 大多数数据库和文件连接器 |
-| 流处理支持 | ~70 | 89% | 大多数连接器，特别是 CDC 和消息队列 |
-| **可靠性** | | | |
-| Exactly-Once | ~45 | 57% | 文件连接器、JDBC、Kafka |
-| **性能** | | | |
-| 并行度 | ~55 | 70% | 大多数数据库和文件连接器 |
-| 列投影 | ~25 | 32% | JDBC、文件、一些专业化连接器 |
-| **高级特性** | | | |
-| 用户自定义分片 | ~15 | 19% | CDC、一些文件连接器 |
-| 多表读取 | ~25 | 32% | JDBC 和一些数据库连接器 |
-| 多模态支持 | ~10 | 13% | 文件和一些专业化连接器 |
-
-### 目标连接器特性分布
-
-| 特性 | 数量 | 百分比 | 示例 |
-|--------|-------|------------|----------|
-| **引擎支持** | | | |
-| 三引擎全支持 | ~70 | 90% | 大多数数据库和文件连接器 |
-| 仅 Spark + Flink | ~6 | 8% | 一些专业化连接器 |
-| 仅 Flink + Zeta | ~2 | 3% | 专业化场景 |
-| **可靠性** | | | |
-| Exactly-Once | ~40 | 51% | JDBC、Kafka、文件连接器 |
-| **数据能力** | | | |
-| CDC 支持 | ~5 | 6% | 仅限于专业化数据库目标 |
-| 多表写入 | ~15 | 19% | JDBC 和一些数据库目标 |
-| 多模态支持 | ~10 | 13% | 文件和专业化连接器 |
-
-## 连接器选择指南
-
-### 基于用例的建议
-
-#### 高吞吐量批处理
-- **推荐源**: Jdbc、文件连接器（LocalFile、HdfsFile、S3File）
-- **推荐目标**: Jdbc、文件连接器、数据湖格式（Iceberg、Hudi）
-- **关键特性**: 批处理支持、并行度、列投影
-
-#### 实时流处理
-- **推荐源**: CDC 连接器、Kafka、文件连接器（流模式）
-- **推荐目标**: Kafka、Jdbc（支持事务）、实时数据库
-- **关键特性**: 流处理支持、exactly-once、低延迟
-
-#### Exactly-Once 保证
-- **推荐源**: 文件连接器、JDBC、Kafka
-- **推荐目标**: JDBC（XA 事务）、Kafka（2PC）、文件连接器
-- **关键特性**: Exactly-once、事务支持、状态管理
-
-#### 多表操作
-- **推荐源**: 支持多表的 JDBC 连接器
-- **推荐目标**: 支持动态表标识符的 JDBC
-- **关键特性**: 多表读写、占位符支持
-
-#### 云集成
-- **推荐源**: 原生云连接器、支持云存储的文件连接器
-- **推荐目标**: 云专用连接器、文件连接器
-- **示例**: S3File、OSSFile、Snowflake、Redshift、MaxCompute
-
-#### 高级分析
-- **推荐源**: 数据湖格式、分析型数据库
-- **推荐目标**: 数据湖格式（Iceberg、Hudi、Paimon）、OLAP 数据库
-- **示例**: Clickhouse、Doris、StarRocks、Druid
-
-## 引擎兼容性说明
-
-### SeaTunnel Zeta（推荐）
-- **优势**: 最佳性能、最多特性、统一 API
-- **连接器覆盖**: ~82% 源，~90% 目标
-- **用例**: 生产部署、性能关键型工作负载
-
-### Apache Flink
-- **优势**: 流处理卓越、容错性
-- **连接器覆盖**: ~95% 源，~98% 目标
-- **用例**: 复杂流处理、有状态处理
-
-### Apache Spark
-- **优势**: 批处理、生态系统集成
-- **连接器覆盖**: ~90% 源，~98% 目标
-- **用例**: 大规模批处理、ETL 工作流
-
-## 数据格式支持
-
-| 数据格式 | 源支持 | 目标支持 | 主要连接器 |
-|-------------|----------------|---------------|------------------|
-| **JSON** | ✅ 大多数 | ✅ 大多数 | 通用默认格式 |
-| **CSV** | ✅ 文件 | ✅ 文件 | LocalFile、HdfsFile、S3File |
-| **Avro** | ✅ Kafka/文件 | ✅ Kafka/文件 | Kafka、文件连接器 |
-| **Parquet** | ✅ 文件/Hive | ✅ 文件/Hive | LocalFile、HdfsFile、Hive |
-| **ORC** | ✅ 文件/Hive | ✅ 文件/Hive | LocalFile、HdfsFile、Hive |
-| **Text** | ✅ 文件/Kafka | ✅ 文件/Kafka | 文件连接器、Kafka |
-| **XML** | ✅ 文件 | ✅ 文件 | 文件连接器 |
-| **Protobuf** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Canal-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Debezium-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **Maxwell-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-| **OGG-JSON** | ✅ Kafka | ✅ Kafka | Kafka |
-
-## 快速开始
-
-### 快速设置
-
-1. **选择引擎**: 选择 SeaTunnel Zeta 以获得最佳性能
-2. **选择连接器**: 使用上述矩阵选择合适的源/目标
-3. **安装插件**: 下载所需的连接器 JAR 文件
-4. **配置作业**: 基于特性要求创建配置
-5. **测试和部署**: 验证配置并运行生产作业
-
-### 最佳实践
-
-1. **特性匹配**: 选择支持所需特性的连接器
-2. **引擎选择**: 尽可能使用 SeaTunnel Zeta 以获得最大兼容性
-3. **性能**: 在支持的地方启用并行度和批处理
-4. **可靠性**: 为关键工作负载优先考虑 exactly-once 支持
-5. **监控**: 监控连接器性能并调整配置
-
-## 贡献
-
-想要添加新连接器或改进现有连接器？请查看：
-- [贡献者指南](../developer/contribution-guide.md)
-- [连接器开发指南](../developer/connector-development)
-- [社区论坛](https://github.com/apache/seatunnel/discussions)
-
----
-
-*此矩阵基于官方文档反映了 SeaTunnel 连接器的当前状态。要获取最新信息，请参考各个连接器的文档页面。特性可用性可能因版本而异。*
\ No newline at end of file
diff --git a/docs/zh/connector-v2/sink/Lance.md
b/docs/zh/connectors/sink/Lance.md
similarity index 97%
rename from docs/zh/connector-v2/sink/Lance.md
rename to docs/zh/connectors/sink/Lance.md
index 1edf460336..1bca8c400e 100644
--- a/docs/zh/connector-v2/sink/Lance.md
+++ b/docs/zh/connectors/sink/Lance.md
@@ -16,7 +16,7 @@ Lance 格式的 Sink 连接器。支持创建和写入数据集、Lance 命名
## 主要特性
-- [] [精确一次语义](../../concept/connector-v2-features.md)
+- [] [精确一次语义](../../introduction/concepts/connector-v2-features.md)
## 依赖
diff --git a/docs/zh/developer/architecture/module-design.md
b/docs/zh/developer/architecture/module-design.md
deleted file mode 100644
index f01c6b87e8..0000000000
--- a/docs/zh/developer/architecture/module-design.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 模块设计
----
-
-# 待办: 描述连接器、转换器和引擎的内部设计模式。
diff --git a/docs/zh/developer/architecture/project-structure.md
b/docs/zh/developer/architecture/project-structure.md
deleted file mode 100644
index 7ec77e9476..0000000000
--- a/docs/zh/developer/architecture/project-structure.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 项目结构
----
-
-# 待办: 解释项目模块：API、引擎、核心、连接器、格式、端到端等。
diff --git a/docs/zh/developer/connector-development/catalog-api.md
b/docs/zh/developer/connector-development/catalog-api.md
deleted file mode 100644
index 5524871e32..0000000000
--- a/docs/zh/developer/connector-development/catalog-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 目录 API
----
-
-# 待办: 与文档目录相关的应用程序编程接口（API）。
diff --git a/docs/zh/developer/connector-development/cdc-connector-guide.md
b/docs/zh/developer/connector-development/cdc-connector-guide.md
deleted file mode 100644
index f9a3076747..0000000000
--- a/docs/zh/developer/connector-development/cdc-connector-guide.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: CDC连接器指南
----
-
-# 待办: 开发CDC连接器的最佳实践。
diff --git a/docs/zh/developer/connector-development/overview.md
b/docs/zh/developer/connector-development/overview.md
deleted file mode 100644
index 9dffb948df..0000000000
--- a/docs/zh/developer/connector-development/overview.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 连接器开发概述
----
-
-# 待办: 高级连接器开发指南（源、汇、配置、检查点）。
diff --git a/docs/zh/developer/connector-development/sink-api.md
b/docs/zh/developer/connector-development/sink-api.md
deleted file mode 100644
index 6b12f6c565..0000000000
--- a/docs/zh/developer/connector-development/sink-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Sink API
----
-
-# TODO: 描述SeaTunnelSink API的文档
diff --git a/docs/zh/developer/connector-development/source-api.md
b/docs/zh/developer/connector-development/source-api.md
deleted file mode 100644
index dc0df61c50..0000000000
--- a/docs/zh/developer/connector-development/source-api.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Source API
----
-
-# TODO: 描述SeaTunnelSource API的文档
\ No newline at end of file
diff --git a/docs/zh/developer/contribution-guide.md
b/docs/zh/developer/contribution-guide.md
deleted file mode 100644
index 3d3b63f5f8..0000000000
--- a/docs/zh/developer/contribution-guide.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 贡献指南
----
-
-# 待办: 整合并总结docs/zh/contribution/*文件中的内容。
diff --git a/docs/zh/developer/e2e-testing.md b/docs/zh/developer/e2e-testing.md
deleted file mode 100644
index bf5392aacf..0000000000
--- a/docs/zh/developer/e2e-testing.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: E2E 测试
----
-
-# 待办: 基于seatunnel-e2e模块，记录端到端测试实践。
diff --git a/docs/zh/developer/engine-development.md
b/docs/zh/developer/engine-development.md
deleted file mode 100644
index 62249debea..0000000000
--- a/docs/zh/developer/engine-development.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: 引擎开发
----
-
-# 待办: 描述SeaTunnel引擎的内部架构和开发指南。
diff --git a/docs/zh/developer/transform-development.md
b/docs/zh/developer/transform-development.md
deleted file mode 100644
index 0a08e93fcf..0000000000
--- a/docs/zh/developer/transform-development.md
+++ /dev/null
@@ -1,5 +0,0 @@
----
-title: Transform 开发
----
-
-# 待办: 描述如何开发与transform-v2兼容的自定义转换
diff --git a/docs/zh/introduction/concepts/config-encryption-decryption.md
b/docs/zh/introduction/concepts/config-encryption-decryption.md
new file mode 100644
index 0000000000..fafc4bf8ae
--- /dev/null
+++ b/docs/zh/introduction/concepts/config-encryption-decryption.md
@@ -0,0 +1,235 @@
+# 配置文件加密和解密
+
+## 介绍
+
+在大多数生产环境中，需要对敏感的配置项（如密码）进行加密，不能以明文形式存储。SeaTunnel 为此提供了一个方便的一站式解决方案。
+
+## 如何使用
+
+SeaTunnel 具备Base64编码和解码的功能，但不建议在生产环境中使用，SeaTunnel
建议用户根据自身需求，实现个性化的加密和解密逻辑。您可以参考本章节[如何实现用户自定义的加密和解密](#如何实现用户自定义的加密和解密)以获取更多相关细节。
+
+Base64编码默认支持加密以下参数：
+- username
+- password
+- auth
+- token
+- access_key
+- secret_key
+
+用户也可以在 `shade.options` 指定要用于加解密的参数.
+
+接下来，将展示如何快速使用 SeaTunnel 自带的 `base64` 加密功能：
+
+1. 在配置文件的环境变量（env）部分新增了选项 `shade.identifier` 和
`shade.options`。`shade.identifier`用于表示您想要使用的加密方法，`shade.options`用于指定您想加解密的参数。
+ 2. 在这个示例中，我们在配置文件中添加了 `shade.identifier = base64`，如下所示：
+
+ ```hocon
+ #
+ # Licensed to the Apache Software Foundation (ASF) under one or more
+ # contributor license agreements. See the NOTICE file distributed with
+ # this work for additional information regarding copyright ownership.
+ # The ASF licenses this file to You under the Apache License, Version 2.0
+ # (the "License"); you may not use this file except in compliance with
+ # the License. You may obtain a copy of the License at
+ #
+ # http://www.apache.org/licenses/LICENSE-2.0
+ #
+ # Unless required by applicable law or agreed to in writing, software
+ # distributed under the License is distributed on an "AS IS" BASIS,
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
implied.
+ # See the License for the specific language governing permissions and
+ # limitations under the License.
+ #
+
+ env {
+ parallelism = 1
+ shade.identifier = "base64"
+ shade.options = ["username", "password", "f1", "config.f1",
"config2.list"]
+ }
+
+ source {
+ MySQL-CDC {
+ plugin_output = "fake"
+ parallelism = 1
+ server-id = 5656
+ port = 56725
+ hostname = "127.0.0.1"
+ username = "seatunnel"
+ password = "seatunnel_password"
+ database-name = "inventory_vwyw0n"
+ table-name = "products"
+ url = "jdbc:mysql://localhost:56725"
+ f1 = "seatunnel"
+ # custom shade options
+ config1.f1 = "seatunnel"
+ config2.list = ["seatunnel", "seatunnel", "seatunnel"]
+ }
+ }
+
+ transform {
+ }
+
+ sink {
+ # 将数据输出到 Clickhouse。
+ Clickhouse {
+ host = "localhost:8123"
+ database = "default"
+ table = "fake_all"
+ username = "seatunnel"
+ password = "seatunnel_password"
+
+ # cdc options
+ primary_key = "id"
+ support_upsert = true
+ }
+ }
+ ```
+3. 通过Shell脚本调用不同的计算引擎来对配置文件进行加密操作。在本示例中，我们使用 Zeta 引擎对配置文件进行加密。
+
+ ```shell
+ ${SEATUNNEL_HOME}/bin/seatunnel.sh --config config/v2.batch.template
--encrypt
+ ```
+
+ 然后，您可以在终端中看到加密后的配置文件。
+
+ ```log
+ 2023-02-20 17:50:58,319 INFO
org.apache.seatunnel.core.starter.command.ConfEncryptCommand - Encrypt config:
+ {
+ "env" : {
+ "parallelism" : 1,
+ "shade.identifier" : "base64"
+ },
+ "source" : [
+ {
+ "url" : "jdbc:mysql://localhost:56725",
+ "hostname" : "127.0.0.1",
+ "password" : "c2VhdHVubmVsX3Bhc3N3b3Jk",
+ "port" : 56725,
+ "database-name" : "inventory_vwyw0n",
+ "parallelism" : 1,
+ "plugin_output" : "fake",
+ "table-name" : "products",
+ "plugin_name" : "MySQL-CDC",
+ "server-id" : 5656,
+ "username" : "c2VhdHVubmVs",
+ "f1" : "c2VhdHVubmVs",
+ "config1.f1" : "c2VhdHVubmVs",
+ "config2.list" : ["c2VhdHVubmVs","c2VhdHVubmVs","c2VhdHVubmVs"]
+ }
+ ],
+ "transform" : [],
+ "sink" : [
+ {
+ "database" : "default",
+ "password" : "c2VhdHVubmVsX3Bhc3N3b3Jk",
+ "support_upsert" : true,
+ "host" : "localhost:8123",
+ "plugin_name" : "Clickhouse",
+ "primary_key" : "id",
+ "table" : "fake_all",
+ "username" : "c2VhdHVubmVs"
+ }
+ ]
+ }
+ ```
+4. 当然，不仅支持加密配置文件，还支持对配置文件的解密。如果用户想要查看解密后的配置文件，可以执行以下命令：
+
+ ```shell
+ ${SEATUNNEL_HOME}/bin/seatunnel.sh --config config/v2.batch.template
--decrypt
+ ```
+
+## 如何实现用户自定义的加密和解密
+
+如果您希望自定义加密方法和加密配置，本章节将帮助您解决问题。
+
+1. 创建一个 java maven 项目
+
+2. 在 maven 依赖中添加 `seatunnel-api` 模块，如下所示:
+
+ ```xml
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-api</artifactId>
+ <version>${seatunnel.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ ```
+3. 创建一个 java 类并实现 `ConfigShade` 接口，该接口包含以下方法：
+
+ ```java
+ /**
+ * The interface that provides the ability to encrypt and decrypt {@link
+ * org.apache.seatunnel.shade.com.typesafe.config.Config}
+ */
+ public interface ConfigShade {
+
+ /**
+ * The unique identifier of the current interface, used it to select
the correct {@link
+ * ConfigShade}
+ */
+ String getIdentifier();
+
+ /**
+ * Encrypt the content
+ *
+ * @param content The content to encrypt
+ */
+ String encrypt(String content);
+
+ /**
+ * Decrypt the content
+ *
+ * @param content The content to decrypt
+ */
+ String decrypt(String content);
+
+ /** To expand the options that user want to encrypt */
+ default String[] sensitiveOptions() {
+ return new String[0];
+ }
+ }
+ ```
+4. 在 `resources/META-INF/services` 目录下创建名为
`org.apache.seatunnel.api.configuration.ConfigShade`的文件， 文件内容是您在步骤 3
中定义的类的完全限定类名。
+5. 将其打成 jar 包, 并添加到 `${SEATUNNEL_HOME}/lib` 目录下。
+6. 将选项 `shade.identifier` 的值更改为上面定义在配置文件中的 `ConfigShade#getIdentifier` 的值。
+
+### 在加密解密方法中使用自定义参数
+
+如果您想要使用自定义参数进行加密和解密，可以按照以下步骤操作：
+1. 在配置文件的env 中添加`shade.properties`配置，该配置的值是键值对形式（键的类型必须是字符串） ，如下所示：
+
+ ```hocon
+ env {
+ shade.properties = {
+ suffix = "666"
+ }
+ }
+
+ ```
+2. 覆写 `ConfigShade` 接口的 `open` 方法，如下所示：
+
+ ```java
+ public static class ConfigShadeWithProps implements ConfigShade {
+
+ private String suffix;
+ private String identifier = "withProps";
+
+ @Override
+ public void open(Map<String, Object> props) {
+ this.suffix = String.valueOf(props.get("suffix"));
+ }
+ }
+ ```
+ 3. 在加密和解密方法中使用open 方法中传入的参数，如下所示：
+
+ ```java
+ @Override
+ public String encrypt(String content) {
+ return content + suffix;
+ }
+
+ @Override
+ public String decrypt(String content) {
+ return content.substring(0, content.length() - suffix.length());
+ }
+ ```
\ No newline at end of file
diff --git a/docs/zh/introduction/concepts/connector-isolated-dependency.md
b/docs/zh/introduction/concepts/connector-isolated-dependency.md
new file mode 100644
index 0000000000..802fe1a005
--- /dev/null
+++ b/docs/zh/introduction/concepts/connector-isolated-dependency.md
@@ -0,0 +1,50 @@
+# Connector 依赖隔离加载机制
+
+SeaTunnel 提供了针对每个 connector 的依赖隔离加载机制，方便用户管理不同连接器单独的依赖，同时避免依赖冲突并提升系统的可扩展性。
+当加载 connector 时，SeaTunnel 会从 `${SEATUNNEL_HOME}` 下的 `plugins/connector-xxx`
目录中，查找并加载该 connector 独立的依赖 jar。这种方式确保了不同 connector 所需的依赖不会相互影响，便于在复杂环境下管理大量
connector。
+
+## 实现原理
+
+每个 connector 需要将自己的依赖 jar 放置在 `${SEATUNNEL_HOME}/plugins/connector-xxx`
目录下的独立子目录中（需要手动创建）。
+子目录名称由 `plugin-mapping` 文件中的 value 值指定。SeaTunnel 启动并加载 connector 时，只会加载对应目录下的
jar，从而实现依赖的隔离。
+
+目前，Zeta 引擎会保证同一个任务不同connector的jar分开加载。其他两个引擎仍然会将所有 connector 的依赖 jar
一起加载，同一个任务放置了不同版本的jar在Spark/Flink环境可能导致依赖冲突。
+
+## 目录结构示例
+
+- 通过`${SEATUNNEL_HOME}/connectors/plugin-mapping.properties`
获取每个connector对应的文件夹目录命名。
+
+以AmazonDynamodb为例，假设在 `plugin-mapping` 文件中有以下配置：
+```
+seatunnel.source.AmazonDynamodb = connector-amazondynamodb
+```
+
+则对应的connector依赖目录就是value值 `connector-amazondynamodb`。
+
+最终的目录结构如下所示：
+
+```
+SEATUNNEL_HOME/
+ plugins/
+ connector-amazondynamodb/
+ dependency1.jar
+ dependency2.jar
+ connector-xxx/
+ dependencyA.jar
+ dependencyB.jar
+```
+
+## 限制说明
+
+- 在Zeta引擎中，请确保所有节点的 `${SEATUNNEL_HOME}/plugins/` 目录结构一致。都需要包含相同的子目录和依赖 jar。
+- 任何没有以`connector-`开头的目录或者jar都将被当作通用依赖目录处理，所有引擎和connector都会加载此类jar。
+- 在Zeta引擎中，可以通过将通用的jar放到 `${SEATUNNEL_HOME}/lib/` 目录下来实现所有 connector 的共享依赖。
+
+## 验证
+
+- 通过追踪任务日志，确认每个 connector 只加载了其独立的依赖 jar。
+
+ ```log
+ 2025-08-13T17:55:48.7732601Z [] 2025-08-13 17:55:47,270 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - find connector
jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Jdbc'}:
[file:/tmp/seatunnel/plugins/Jdbc/lib/vertica-jdbc-12.0.3-0.jar,
file:/tmp/seatunnel/connectors/connector-jdbc-2.3.13-SNAPSHOT-2.12.15.jar]
+ ```
+
diff --git a/docs/zh/transforms/common-options.md
b/docs/zh/transforms/common-options/common-options.md
similarity index 100%
rename from docs/zh/transforms/common-options.md
rename to docs/zh/transforms/common-options/common-options.md
diff --git a/docs/zh/transforms/copy.md b/docs/zh/transforms/copy.md
index 707bc5233e..1139474678 100644
--- a/docs/zh/transforms/copy.md
+++ b/docs/zh/transforms/copy.md
@@ -18,7 +18,7 @@
### 常见选项 [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情。
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情。
## 示例
diff --git a/docs/zh/transforms/data-validator.md
b/docs/zh/transforms/data-validator.md
index c744c0d9a8..c35f47825f 100644
--- a/docs/zh/transforms/data-validator.md
+++ b/docs/zh/transforms/data-validator.md
@@ -124,7 +124,7 @@ DataValidator 转换插件根据配置的规则验证字段值，并基于指定
### 通用选项 [string]
-转换插件通用参数，请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件通用参数，请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git a/docs/zh/transforms/dynamic-compile.md
b/docs/zh/transforms/dynamic-compile.md
index 1fa055591a..8a9e7dfe0c 100644
--- a/docs/zh/transforms/dynamic-compile.md
+++ b/docs/zh/transforms/dynamic-compile.md
@@ -26,7 +26,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情。
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情。
### compile_language [Enum]
diff --git a/docs/zh/transforms/embedding.md b/docs/zh/transforms/embedding.md
index 9379264236..415dae4766 100644
--- a/docs/zh/transforms/embedding.md
+++ b/docs/zh/transforms/embedding.md
@@ -176,7 +176,7 @@ vectorization_fields {
### common options
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例配置
diff --git a/docs/zh/transforms/field-mapper.md
b/docs/zh/transforms/field-mapper.md
index 9c2f82dee8..aa50e3588a 100644
--- a/docs/zh/transforms/field-mapper.md
+++ b/docs/zh/transforms/field-mapper.md
@@ -18,7 +18,7 @@
### common options [config]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git a/docs/zh/transforms/filter-rowkind.md
b/docs/zh/transforms/filter-rowkind.md
index 60bb620853..58e625b232 100644
--- a/docs/zh/transforms/filter-rowkind.md
+++ b/docs/zh/transforms/filter-rowkind.md
@@ -25,7 +25,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git a/docs/zh/transforms/filter.md b/docs/zh/transforms/filter.md
index 66937b00b9..3a6cbdb255 100644
--- a/docs/zh/transforms/filter.md
+++ b/docs/zh/transforms/filter.md
@@ -25,7 +25,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git a/docs/zh/transforms/jsonpath.md b/docs/zh/transforms/jsonpath.md
index 19d8b292b5..c2984a82d2 100644
--- a/docs/zh/transforms/jsonpath.md
+++ b/docs/zh/transforms/jsonpath.md
@@ -15,7 +15,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
### row_error_handle_way [Enum]
diff --git a/docs/zh/transforms/llm.md b/docs/zh/transforms/llm.md
index c6cead3dfd..d60e4ccb11 100644
--- a/docs/zh/transforms/llm.md
+++ b/docs/zh/transforms/llm.md
@@ -152,7 +152,7 @@ transform {
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## tips
大模型API接口通常会有速率限制，可以配合Seatunnel的限速配置，已确保任务顺利运行。
diff --git a/docs/zh/transforms/replace.md b/docs/zh/transforms/replace.md
index 6f8c15743b..f3aea60ce2 100644
--- a/docs/zh/transforms/replace.md
+++ b/docs/zh/transforms/replace.md
@@ -38,7 +38,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git a/docs/zh/transforms/split.md b/docs/zh/transforms/split.md
index 99b61c3677..2c851a59b1 100644
--- a/docs/zh/transforms/split.md
+++ b/docs/zh/transforms/split.md
@@ -28,7 +28,7 @@
### common options [string]
-转换插件的常见参数, 请参考 [Transform Plugin](common-options.md) 了解详情
+转换插件的常见参数, 请参考 [Transform Plugin](common-options/common-options.md) 了解详情
## 示例
diff --git
a/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/file/AllFileSpecificationCheckTest.java
b/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/file/AllFileSpecificationCheckTest.java
index a5c3580070..c8af7b4b6d 100644
---
a/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/file/AllFileSpecificationCheckTest.java
+++
b/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/file/AllFileSpecificationCheckTest.java
@@ -107,11 +107,11 @@ public class AllFileSpecificationCheckTest {
"seatunnel-dist/src/test/java/org/apache/seatunnel/api/file/AllFileSpecificationCheckTest.java",
"docs/zh/connectors/common-options/source-common-options.md",
"docs/zh/connectors/common-options/sink-common-options.md",
- "docs/zh/transforms/common-options.md",
+ "docs/zh/transforms/common-options/common-options.md",
"docs/zh/introduction/concepts/config.md",
"docs/en/connectors/common-options/source-common-options.md",
"docs/en/connectors/common-options/sink-common-options.md",
- "docs/en/transforms/common-options.md",
+ "docs/en/transforms/common-options/common-options.md",
"docs/en/introduction/concepts/config.md",
"seatunnel-api/src/main/java/org/apache/seatunnel/api/options/ConnectorCommonOptions.java",
"seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/resources/fake_to_assert_with_compatible_source_and_result_table_name.conf",
