Commit a2ab166
File tree
- docs/en
- concept
- connector-v2
- formats
- sink
- source
- contribution
- seatunnel-engine
- start-v2
- docker
- locally
- transform-v2
- seatunnel-api
- src
- main/java/org/apache/seatunnel/api
- common
- metrics
- configuration
- util
- env
- serialization
- sink
- source
- state
- table
- catalog
- exception
- connector
- factory
- type
- transform
- test/java/org/apache/seatunnel/api
- configuration
- util
- env
- seatunnel-common
- src
- main/java/org/apache/seatunnel/common
- config
- constants
- exception
- utils
- function
- test/java/org/apache/seatunnel/common
- config
- utils
- seatunnel-connectors-v2
- connector-amazondynamodb
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb
- config
- exception
- serialize
- sink
- source
- test/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb
- connector-assert
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/assertion
- excecutor
- exception
- rule
- sink
- test/java/org/apache/seatunnel/flink/assertion
- rule
- connector-cassandra
- src/main/java/org/apache/seatunnel/connectors/seatunnel/cassandra
- client
- config
- exception
- sink
- source
- util
- connector-cdc
- connector-cdc-base
- src/main/java
- io/debezium/relational
- org/apache/seatunnel/connectors/cdc
- base
- config
- option
- relational
- connection
- source
- enumerator
- splitter
- state
- event
- offset
- reader
- external
- split
- state
- wartermark
- utils
- debezium
- row
- connector-cdc-mysql
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql
- config
- source
- eumerator
- offset
- reader/fetch
- binlog
- scan
- utils
- test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/testutils
- connector-cdc-sqlserver
- src/main/java
- io/debezium/connector/sqlserver
- org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source
- config
- source
- eumerator
- offset
- reader/fetch
- scan
- transactionlog
- utils
- connector-clickhouse
- src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse
- config
- exception
- shard
- sink
- client
- executor
- file
- inject
- source
- state
- util
- connector-common
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/common
- schema
- sink
- source
- reader
- fetcher
- splitreader
- test/java/org/apache/seatunnel/connector/common/schema
- connector-console
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/console/sink
- test/java/org/apache/seatunnel/connectors/seatunnel/console/sink
- connector-datahub
- src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub
- config
- exception
- sink
- connector-dingtalk
- src/main/java/org/apache/seatunnel/connectors/seatunnel
- config
- exception
- sink
- connector-doris
- src/main/java/org/apache/seatunnel/connectors/doris
- client
- config
- exception
- sink
- util
- connector-elasticsearch
- src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch
- client
- config
- constant
- dto
- source
- exception
- serialize
- index
- impl
- source
- type
- impl
- sink
- source
- state
- util
- connector-email
- src/main/java/org/apache/seatunnel/connectors/seatunnel/email
- config
- exception
- sink
- connector-fake
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/fake
- config
- exception
- source
- utils
- test/java/org/apache/seatunnel/connectors/seatunnel/fake/source
- connector-file
- connector-file-base-hadoop
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs
- sink
- source
- config
- connector-file-base
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/file
- config
- exception
- sink
- commit
- config
- util
- writer
- source
- reader
- split
- test/java/org/apache/seatunnel/connectors/seatunnel/file/writer
- connector-file-ftp
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp
- config
- sink
- source
- system
- connector-file-hadoop
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs
- sink
- source
- connector-file-local
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local
- sink
- source
- config
- connector-file-oss-jindo
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss
- config
- exception
- sink
- source
- connector-file-oss
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss
- config
- sink
- source
- connector-file-s3
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3
- config
- sink
- source
- connector-file-sftp
- src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp
- config
- sink
- source
- system
- connector-google-sheets
- src/main/java/org/apache/seatunnel/connectors/seatunnel/google/sheets
- config
- deserialize
- exception
- source
- connector-hbase
- src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase
- config
- exception
- sink
- connector-hive
- src/main/java/org/apache/seatunnel/connectors/seatunnel/hive
- commit
- config
- exception
- sink
- source
- utils
- connector-http
- connector-http-base
- src/main/java/org/apache/seatunnel/connectors/seatunnel/http
- client
- config
- exception
- sink
- source
- util
- connector-http-feishu
- connector-http-gitlab
- src/main/java/org/apache/seatunnel/connectors/seatunnel/gitlab/source
- config
- exception
- connector-http-jira
- src/main/java/org/apache/seatunnel/connectors/seatunnel/jira/source
- config
- connector-http-klaviyo
- src/main/java/org/apache/seatunnel/connectors/seatunnel/klaviyo/source
- config
- exception
- connector-http-lemlist
- src/main/java/org/apache/seatunnel/connectors/seatunnel/lemlist/source
- config
- exception
- connector-http-myhours
- src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source
- config
- exception
- connector-http-notion
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/notion/source
- config
- exception
- test/java/org/apache/seatunnel/connectors/seatunnel/notion
- connector-http-onesignal
- src/main/java/org/apache/seatunnel/connectors/seatunnel/onesignal/source
- config
- exception
- connector-http-persistiq
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/persistiq/source
- config
- test/java/org/apache/seatunnel/connectors/seatunnel/persistiq
- connector-http-wechat
- src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink
- config
- connector-hudi
- src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi
- config
- exception
- source
- util
- connector-iceberg
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/iceberg
- config
- data
- exception
- source
- enumerator
- scan
- reader
- split
- test/java/org/apache/seatunnel/connectors/seatunnel/iceberg
- connector-influxdb
- src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb
- client
- config
- converter
- exception
- serialize
- sink
- source
- connector-iotdb
- src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb
- config
- constant
- exception
- serialize
- sink
- source
- connector-jdbc
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog
- config
- exception
- internal
- connection
- converter
- dialect
- db2
- dm
- gbase8a
- mysql
- oracle
- phoenix
- psql
- redshift
- saphana
- sqlite
- sqlserver
- tablestore
- teradata
- executor
- options
- split
- xa
- sink
- source
- utils
- test/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog
- internal/xa
- connector-kafka
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/kafka
- config
- exception
- serialize
- sink
- source
- state
- test/java/org/apache/seatunnel/connectors/seatunnel/kafka
- connector-kudu
- src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu
- config
- exception
- kuduclient
- sink
- source
- state
- connector-maxcompute
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute
- config
- exception
- sink
- source
- util
- test/java
- connector-mongodb
- src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb
- config
- data
- exception
- sink
- source
- connector-neo4j
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/neo4j
- config
- exception
- sink
- source
- test/java/org.apache.seatunnel.connectors.seatunnel.neo4j.source
- connector-openmldb
- src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb
- config
- exception
- source
- connector-pulsar
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/pulsar
- config
- exception
- source
- enumerator
- cursor
- start
- stop
- discoverer
- topic
- reader
- split
- test/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source
- connector-rabbitmq
- src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq
- client
- config
- exception
- sink
- source
- split
- connector-redis
- src/main/java/org/apache/seatunnel/connectors/seatunnel/redis
- config
- exception
- sink
- source
- connector-s3-redshift
- src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift
- commit
- config
- exception
- sink
- connector-selectdb-cloud
- src/main/java/org/apache/seatunnel/connector/selectdb
- config
- exception
- rest
- serialize
- sink
- committer
- writer
- util
- connector-sentry
- src/main/java/org/apache/seatunnel/connectors/seatunnel/sentry
- config
- exception
- sink
- connector-slack
- src/main/java/org/apache/seatunnel/connectors/seatunnel/slack
- client
- exception
- sink
- connector-socket
- src/main/java/org/apache/seatunnel/connectors/seatunnel/socket
- config
- exception
- sink
- source
- connector-starrocks
- src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks
- client
- config
- exception
- serialize
- sink
- connector-tablestore
- src/main/java/org/apache/seatunnel/connectors/seatunnel/tablestore
- config
- exception
- serialize
- sink
- connector-tdengine
- src
- main/java/org/apache/seatunnel/connectors/seatunnel/tdengine
- config
- exception
- sink
- source
- typemapper
- test/java/org/apache/seatunnel/connectors/seatunnel/tdengine
- seatunnel-core
- seatunnel-core-starter
- src
- main/java/org/apache/seatunnel/core/starter
- command
- enums
- exception
- execution
- utils
- test/java/org/apache/seatunnel/core/starter/utils
- seatunnel-flink-starter
- seatunnel-flink-13-starter
- src/main/java/org/apache/seatunnel/core/starter/flink
- args
- command
- execution
- utils
- seatunnel-flink-15-starter
- src/main/java/org/apache/seatunnel/core/starter/flink
- args
- command
- execution
- utils
- seatunnel-spark-starter
- seatunnel-spark-2-starter
- src
- main/java/org/apache/seatunnel/core/starter/spark
- args
- command
- execution
- test/java/org/apache/seatunnel/core/starter/spark
- args
- utils
- seatunnel-spark-3-starter
- src/main/java/org/apache/seatunnel/core/starter/spark
- args
- command
- execution
- seatunnel-starter
- src
- main/java/org/apache/seatunnel/core/starter/seatunnel
- args
- command
- jvm
- test/java/org/apache/seatunnel/core/starter/seatunnel/jvm
- seatunnel-dist
- seatunnel-e2e
- seatunnel-connector-v2-e2e
- connector-amazondynamodb-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb
- connector-assert-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/assertion
- connector-cassandra-e2e
- src/test/java/org/apache/seatunnel/connectors/seatunnel/cassandra
- connector-cdc-mysql-e2e
- src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql
- connector-cdc-sqlserver-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/cdc/sqlserver
- connector-clickhouse-e2e
- src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse
- connector-datahub-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/datahub
- connector-doris-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/doris
- connector-elasticsearch-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch
- connector-fake-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/fake
- connector-file-local-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/file/local
- connector-hbase-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/hbase
- connector-http-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/http
- connector-iceberg-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/iceberg
- connector-iceberg-hadoop3-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/iceberg/hadoop3
- connector-influxdb-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/influxdb
- connector-iotdb-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/iotdb
- connector-jdbc-e2e
- src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- internal/xa
- util
- connector-kafka-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/kafka
- connector-mongodb-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb
- connector-neo4j-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/neo4j
- connector-rabbitmq-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/rabbitmq
- connector-redis-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/redis
- connector-selectdb-cloud-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/selectdb
- connector-starrocks-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/starrocks
- connector-tdengine-e2e
- src/test/java/org/apache/seatunnel/e2e/connector/tdengine
- seatunnel-e2e-common
- src/test/java/org/apache/seatunnel/e2e/common
- container
- flink
- seatunnel
- spark
- junit
- util
- seatunnel-engine-e2e
- connector-console-seatunnel-e2e
- connector-seatunnel-e2e-base
- src/test/java/org/apache/seatunnel/engine/e2e
- seatunnel-flink-connector-v2-e2e
- connector-flink-e2e-base
- src/test/java/org/apache/seatunnel/e2e/flink
- connector-jdbc-flink-e2e
- src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc
- seatunnel-spark-connector-v2-e2e
- connector-jdbc-spark-e2e
- src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc
- connector-spark-e2e-base
- src/test/java/org/apache/seatunnel/e2e/spark
- seatunnel-transforms-v2-e2e
- src/test/java/org/apache/seatunnel/e2e/transform
- seatunnel-engine
- seatunnel-engine-client
- src
- main/java/org/apache/seatunnel/engine/client
- job
- test/java/org/apache/seatunnel/engine/client
- seatunnel-engine-common
- src
- main/java/org/apache/seatunnel/engine/common
- config
- server
- exception
- loader
- serializeable
- utils
- test/java/org/apache/seatunnel/engine/common/config
- seatunnel-engine-core
- src/main/java/org/apache/seatunnel/engine/core
- checkpoint
- dag
- actions
- logical
- job
- parse
- protocol/codec
- serializable
- seatunnel-engine-serializer
- serializer-api
- serializer-protobuf
- src
- main/java/org/apache/seatunnel/engine/serializer/protobuf
- test/java/org/apache/seatunnel/engine/serializer/protobuf
- seatunnel-engine-server
- src
- main/java/org/apache/seatunnel/engine/server
- checkpoint
- operation
- dag
- execution
- physical
- config
- execution
- log
- master
- metrics
- operation
- persistence
- protocol/task
- resourcemanager
- opeartion
- resource
- thirdparty
- kubernetes
- yarn
- scheduler
- serializable
- service/slot
- task
- context
- flow
- group
- queue
- disruptor
- operation
- checkpoint
- sink
- source
- record
- statemachine
- utils
- test/java/org/apache/seatunnel/engine/server
- checkpoint
- dag
- execution
- master
- resourcemanager
- seatunnel-engine-storage
- checkpoint-storage-api
- src/main/java/org/apache/seatunnel/engine/checkpoint/storage
- api
- constants
- exception
- checkpoint-storage-plugins
- checkpoint-storage-hdfs
- src
- main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs
- common
- test/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs
- checkpoint-storage-local-file
- src
- main/java/org/apache/seatunnel/engine/checkpoint/storage/localfile
- test/java/org/apache/seatunnel/engine/checkpoint/storage/localfile
- imap-storage-api
- src/main/java/org/apache/seatunnel/engine/imap/storage/api
- imap-storage-plugins
- imap-storage-file
- src
- main/java/org/apache/seatunnel/engine/imap/storage/file
- common
- disruptor
- future
- test/java/org/apache/seatunnel/engine/imap/storage/file
- common
- disruptor
- seatunnel-examples
- seatunnel-engine-examples
- src/main/java/org/apache/seatunnel/example/engine
- seatunnel-flink-connector-v2-example
- src/main/java/org/apache/seatunnel/example/flink/v2
- seatunnel-spark-connector-v2-example
- src/main/java/org/apache/seatunnel/example/spark/v2
- seatunnel-formats
- seatunnel-format-json
- src
- main/java/org/apache/seatunnel/format/json
- canal
- exception
- test/java/org/apache/seatunnel/format/json
- canal
- seatunnel-format-text
- src
- main/java/org/apache/seatunnel/format/text
- exception
- test/java/org/apache/seatunnel/format/text
- seatunnel-plugin-discovery
- src
- main/java/org/apache/seatunnel/plugin/discovery
- test/java/org/apache/seatunnel/plugin/discovery
- seatunnel-shade
- seatunnel-hadoop3-3.1.4-uber
- seatunnel-jackson
- seatunnel-transforms-v2
- src
- main/java/org/apache/seatunnel/transform
- common
- exception
- test/java/org/apache/seatunnel/transform
- seatunnel-translation
- seatunnel-translation-base
- src/main/java/org/apache/seatunnel/translation
- serialization
- sink
- source
- util
- seatunnel-translation-flink
- seatunnel-translation-flink-13
- src
- main/java/org/apache/seatunnel/translation/flink
- serialization
- sink
- source
- utils
- test/java/org/apache/seatunnel/translation/flink/utils
- seatunnel-translation-flink-15
- src/main/java/org/apache/seatunnel/translation/flink
- serialization
- sink
- source
- utils
- seatunnel-translation-spark
- seatunnel-translation-spark-2.4
- src/main/java/org/apache/seatunnel/translation/spark
- serialization
- sink
- writer
- source
- partition
- batch
- micro
- reader
- batch
- micro
- utils
- seatunnel-translation-spark-3.3
- src/main/java/org/apache/seatunnel/translation/spark
- serialization
- sink
- write
- source
- partition
- batch
- micro
- scan
- utils
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
| 2 | + | |
2 | 3 | | |
3 | 4 | | |
4 | | - | |
| 5 | + | |
5 | 6 | | |
6 | 7 | | |
7 | 8 | | |
8 | 9 | | |
9 | 10 | | |
10 | 11 | | |
11 | 12 | | |
12 | | - | |
| 13 | + | |
13 | 14 | | |
14 | 15 | | |
15 | 16 | | |
| |||
82 | 83 | | |
83 | 84 | | |
84 | 85 | | |
| 86 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
9 | 9 | | |
10 | 10 | | |
11 | 11 | | |
12 | | - | |
13 | 12 | | |
14 | 13 | | |
15 | 14 | | |
| |||
49 | 48 | | |
50 | 49 | | |
51 | 50 | | |
52 | | - | |
| 51 | + | |
53 | 52 | | |
54 | 53 | | |
55 | 54 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
| 2 | + | |
2 | 3 | | |
3 | | - | |
| 4 | + | |
4 | 5 | | |
5 | 6 | | |
6 | 7 | | |
| |||
11 | 12 | | |
12 | 13 | | |
13 | 14 | | |
14 | | - | |
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
| 45 | + | |
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
| |||
64 | 64 | | |
65 | 65 | | |
66 | 66 | | |
67 | | - | |
| 67 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
9 | | - | |
10 | | - | |
11 | | - | |
12 | | - | |
13 | | - | |
14 | | - | |
15 | | - | |
16 | | - | |
17 | | - | |
18 | | - | |
19 | | - | |
20 | | - | |
21 | | - | |
22 | | - | |
23 | | - | |
24 | | - | |
25 | | - | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
64 | | - | |
| 64 | + | |
0 commit comments