File tree
200 files changed
+9852
-936
lines changed- docs
- en
- connector-v2
- sink
- source
- transform-v2
- zh
- connector-v2
- sink
- source
- transform-v2
- seatunnel-common/src/main/java/org/apache/seatunnel/common/exception
- seatunnel-connectors-v2
- connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source
- connector-cdc/connector-cdc-base/src
- main/java/org/apache/seatunnel/connectors/cdc/debezium/row
- test/java/org/apache/seatunnel/connectors/cdc/debezium/row
- connector-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/source
- connector-doris/src/main/java/org/apache/seatunnel/connectors/doris
- catalog
- config
- datatype
- sink
- source
- reader
- connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source
- connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source
- connector-file
- connector-file-base/src
- main/java/org/apache/seatunnel/connectors/seatunnel/file
- config
- sink
- config
- writer
- source/reader
- test
- java/org/apache/seatunnel/connectors/seatunnel/file/writer
- resources
- connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos
- sink
- source
- connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp
- sink
- source
- connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs
- sink
- source
- connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo
- sink
- source
- connector-file-local/src
- main/java/org/apache/seatunnel/connectors/seatunnel/file/local
- sink
- source
- test/java/org/apache/seatunnel/connectors/seatunnel/file/local
- connector-file-obs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/obs
- sink
- source
- connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss
- sink
- source
- connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3
- sink
- source
- connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp
- sink
- source
- connector-http
- connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http
- client
- config
- source
- connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source
- config
- connector-jdbc/src
- main/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog/sqlserver
- internal/dialect/opengauss
- utils
- test/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog/sqlserver
- internal/dialect/opengauss
- connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka
- config
- serialize
- sink
- source
- connector-maxcompute/src
- main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source
- test/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source
- connector-mongodb/src
- main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/split
- test/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/split
- connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/source
- connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis
- config
- sink
- source
- connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks
- client
- source
- model
- config
- exception
- sink
- source
- connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/source
- seatunnel-core/seatunnel-starter/src/main/bin
- seatunnel-e2e/seatunnel-connector-v2-e2e
- connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris
- connector-http-e2e/src/test
- java/org/apache/seatunnel/e2e/connector/http
- resources
- connector-kafka-e2e/src/test
- java/org/apache/seatunnel/e2e/connector/kafka
- resources
- connector-starrocks-e2e/src/test
- java/org/apache/seatunnel/e2e/connector/starrocks
- resources
- seatunnel-engine
- seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job
- seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core
- classloader
- dag/logical
- job
- seatunnel-engine-server/src
- main/java/org/apache/seatunnel/engine/server
- dag
- execution
- physical
- master
- rest
- service
- test/java/org/apache/seatunnel/engine/server
- checkpoint
- dag
- master
- seatunnel-formats/seatunnel-format-compatible-connect-json/src/main/java/org/apache/seatunnel/format/compatible/kafka/connect/json
- seatunnel-plugin-discovery/src
- main/java/org/apache/seatunnel/plugin/discovery
- test
- java/org/apache/seatunnel/plugin/discovery/seatunnel
- resources/duplicate/connectors
- seatunnel-transforms-v2
- src
- main/java/org/apache/seatunnel/transform/nlpmodel
- embedding
- remote
- custom
- doubao
- openai
- qianfan
- zhipu
- llm
- test/java/org/apache/seatunnel/transform/embedding
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
200 files changed
+9852
-936
lines changedOriginal file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
46 | 46 |
| |
47 | 47 |
| |
48 | 48 |
| |
| 49 | + | |
49 | 50 |
| |
50 | 51 |
| |
51 | 52 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
45 | 45 |
| |
46 | 46 |
| |
47 | 47 |
| |
| 48 | + | |
48 | 49 |
| |
49 | 50 |
| |
50 | 51 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
48 | 48 |
| |
49 | 49 |
| |
50 | 50 |
| |
| 51 | + | |
51 | 52 |
| |
52 | 53 |
| |
53 | 54 |
| |
|
0 commit comments