Commit 5a516ed
File tree
1,787 files changed
+24022
-149708
lines changed- .github/workflows
- chunjun-assembly
- chunjun-clients
- src/main
- java
- com/dtstack/chunjun/client
- exception
- kubernetes
- local
- standalone
- util
- yarn
- org/apache/flink/yarn
- resources
- chunjun-connectors
- chunjun-connector-binlog
- src
- main/java/com
- alibaba/otter/canal
- filter
- parse/inbound/mysql/ddl
- dtstack/chunjun/connector/binlog
- config
- conf
- converter
- format
- inputformat
- listener
- options
- source
- table
- util
- google/common/collect
- test/java/com/dtstack/chunjun/connector/binlog
- inputformat
- util
- chunjun-connector-cassandra
- src/main/java/com/dtstack/chunjun/connector/cassandra
- config
- conf
- converter
- lookup
- optinos
- sink
- source
- table
- util
- chunjun-connector-clickhouse
- src/main/java/com/dtstack/chunjun/connector/clickhouse
- converter
- dialect
- sink
- source
- table
- util
- chunjun-connector-db2
- src/main/java/com/dtstack/chunjun/connector/db2
- converter
- dialect
- sink
- source
- table
- chunjun-connector-dm
- src/main/java/com/dtstack/chunjun/connector/dm
- converter
- dialect
- sink
- source
- table
- chunjun-connector-doris
- src/main/java/com/dtstack/chunjun/connector/doris
- converter
- exception
- options
- rest
- module
- sink
- source
- table
- chunjun-connector-elasticsearch-base
- src/main/java/com/dtstack/chunjun/connector/elasticsearch
- table
- chunjun-connector-elasticsearch6
- src/main/java/com/dtstack/chunjun/connector/elasticsearch6
- sink
- source
- table
- lookup
- chunjun-connector-elasticsearch7
- src/main/java/com/dtstack/chunjun/connector/elasticsearch7
- sink
- source
- table
- lookup
- chunjun-connector-emqx
- src/main/java/com/dtstack/chunjun/connector/emqx
- config
- conf
- converter
- options
- sink
- source
- table
- util
- chunjun-connector-filesystem/src/main
- java/com/dtstack/chunjun
- streaming/api/functions/sink/filesystem
- table/filesystem
- stream
- compact
- resources/META-INF/services
- chunjun-connector-file
- src/main/java/com/dtstack/chunjun/connector/file
- converter
- source
- table
- chunjun-connector-ftp
- src/main/java/com/dtstack/chunjun/connector/ftp
- client
- excel
- config
- conf
- converter
- extend/ftp
- concurrent
- handler
- iformat
- sink
- source
- spliter
- table
- chunjun-connector-greenplum
- src/main/java/com/dtstack/chunjun/connector/greenplum
- converter
- dialect
- sink
- source
- table
- chunjun-connector-hbase-1.4
- src/main/java/com/dtstack/chunjun/connector/hbase14
- sink
- source
- chunjun-connector-hbase-base
- src
- main/java/com/dtstack/chunjun/connector/hbase
- config
- conf
- converter
- sink
- source
- table
- lookup
- util
- test/java/com/dtstack/chunjun/connector/hbase
- config
- converter
- sink
- source
- util
- chunjun-connector-hbase2
- src/main/java/com/dtstack/chunjun/connector/hbase2
- sink
- source
- chunjun-connector-hdfs
- src/main/java/com/dtstack/chunjun/connector/hdfs
- InputSplit
- config
- conf
- converter
- enums
- options
- sink
- source
- table
- util
- chunjun-connector-hive3
- src/main/java/com/dtstack/chunjun/connector/hive3
- config
- conf
- converter
- enums
- inputSplit
- sink
- source
- util
- chunjun-connector-hive
- src/main/java/com/dtstack/chunjun/connector/hive
- config
- conf
- entity
- enums
- options
- parser
- sink
- table
- util
- chunjun-connector-http
- src/main/java/com/dtstack/chunjun/connector/http
- client
- common
- converter
- inputformat
- outputformat
- sink
- source
- table
- chunjun-connector-iceberg
- src/main/java/com/dtstack/chunjun/connector/iceberg
- config
- conf
- converter
- sink
- source
- chunjun-connector-influxdb
- src/main/java/com/dtstack/chunjun/connector/influxdb
- config
- conf
- constants
- converter
- enums
- sink
- source
- chunjun-connector-jdbc-base
- src
- main/java
- com/dtstack/chunjun/connector/jdbc
- adapter
- config
- conf
- converter
- dialect
- exclusion
- lookup
- provider
- options
- sink
- source
- distribute
- table
- util
- key
- io/vertx
- core/json
- ext/jdbc/impl/actions
- test/java/com/dtstack/chunjun/connector/jdbc
- converter
- sink
- source
- distribute
- table
- util
- chunjun-connector-kafka
- src
- main
- java
- com/dtstack/chunjun/connector
- kafka
- adapter
- conf
- converter
- deserializer
- enums
- partitioner
- serialization
- sink
- source
- table
- util
- upsertkafka/table
- org/apache
- avro
- kafka/clients/consumer/internals
- resources/META-INF/services
- test/java/com/dtstack/chunjun/connector/kafka
- adapter
- conf
- converter
- deserializer
- partitioner
- sink
- source
- chunjun-connector-kudu
- src/main/java/com/dtstack/chunjun/connector/kudu
- config
- conf
- converter
- sink
- source
- table
- lookup
- util
- chunjun-connector-mongodb
- src/main/java/com/dtstack/chunjun/connector/mongodb
- config
- conf
- converter
- datasync
- sink
- source
- table
- lookup
- options
- chunjun-connector-mysqlcdc
- src/main/java/com/dtstack/chunjun/connector/mysqlcdc
- config
- converter
- source
- chunjun-connector-mysqld
- src/main/java/com/dtstack/chunjun/connector/mysqld
- source
- utils
- chunjun-connector-mysql
- src/main/java/com/dtstack/chunjun/connector/mysql
- converter
- dialect
- sink
- source
- table
- chunjun-connector-nebula
- src
- main
- java/com/dtstack/chunjun/connector/nebula
- client
- config
- converter
- lookup
- ngql
- row
- sink
- source
- splitters
- creator
- table
- utils
- resources/META-INF/services
- test/java/com/dtstack/chunjun/connector/nebula
- lookup/ngql
- splitters/creator
- chunjun-connector-oceanbasecdc
- src/main/java/com/dtstack/chunjun/connector/oceanbasecdc
- config
- conf
- converter
- entity
- format
- inputformat
- listener
- options
- source
- table
- chunjun-connector-oceanbase
- src/main/java/com/dtstack/chunjun/connector/oceanbase
- dialect
- sink
- source
- chunjun-connector-oraclelogminer
- src/main/java/com/dtstack/chunjun/connector/oraclelogminer
- config
- conf
- converter
- entity
- format
- inputformat
- listener
- options
- source
- table
- util
- chunjun-connector-oracle
- src
- main/java/com/dtstack/chunjun/connector/oracle
- converter
- dialect
- sink
- source
- table
- util/increment
- test/java
- chunjun-connector-pgwal
- src/main/java/com/dtstack/chunjun/connector
- api
- pgwal
- conf
- converter
- inputformat
- listener
- options
- source
- table
- util
- chunjun-connector-postgresql
- src/main/java/com/dtstack/chunjun/connector/postgresql
- converter
- dialect
- sink
- source
- table
- chunjun-connector-rabbitmq
- src/main/java/com/dtstack/chunjun/connector/rabbitmq
- options
- source
- table
- chunjun-connector-redis
- src/main/java/com/dtstack/chunjun/connector/redis
- adapter
- config
- conf
- connection
- converter
- enums
- inputsplit
- lookup
- options
- sink
- source
- table
- util
- chunjun-connector-rocketmq
- src/main/java/com/dtstack/chunjun/connector/rocketmq
- config
- conf
- converter
- source
- deserialization
- watermark
- table
- utils
- chunjun-connector-s3
- src/main/java/com/dtstack/chunjun/connector/s3
- config
- conf
- converter
- sink
- source
- table
- util
- chunjun-connector-saphana
- src
- main/java/com/dtstack/chunjun/connector/saphana
- converter
- dialect
- sink
- source
- table
- test/java/com/dtstack/chunjun/connector/saphana
- chunjun-connector-socket
- src/main/java/com/dtstack/chunjun/connector/socket
- client
- entity
- inputformat
- source
- chunjun-connector-solr
- src/main/java/com/dtstack/chunjun/connector/solr
- client
- converter
- sink
- source
- table
- chunjun-connector-sqlservercdc
- src/main/java/com/dtstack/chunjun/connector/sqlservercdc
- config
- conf
- convert
- entity
- format
- inputFormat
- listener
- options
- source
- table
- util
- chunjun-connector-sqlserver
- src/main/java/com/dtstack/chunjun/connector/sqlserver
- converter
- dialect
- sink
- source
- table
- util/increment
- chunjun-connector-starrocks
- src/main/java/com/dtstack/chunjun/connector/starrocks
- config
- conf
- connection
- converter
- options
- sink
- source
- be
- entity
- streamload
- table
- util
- chunjun-connector-stream
- src/main/java/com/dtstack/chunjun/connector/stream
- config
- conf
- converter
- lookup
- options
- sink
- source
- table
- util
- chunjun-connector-sybase
- src/main/java/com/dtstack/chunjun/connector/sybase
- converter
- dialect
- source
- table
- chunjun-connector-vertica11
- src/main/java/com/dtstack/chunjun/connector/vertica11
- config
- converter
- dialect
- lookup
- options
- provider
- sink
- source
- table
- chunjun-core
- src
- main
- java
- com/dtstack/chunjun
- annotation
- cdc
- cache
- config
- conf
- ddl
- definition
- exception
- handler
- worker
- classloader
- config
- conf
- constants
- converter
- decoder
- dirty
- consumer
- impl
- manager
- utils
- element
- column
- enums
- environment
- factory
- interceptor
- lookup
- cache
- config
- options
- mapping
- metrics
- options
- restore
- security
- sink
- format
- source
- format
- options
- sql
- parser
- table
- connector
- sink
- source
- options
- throwable
- typeutil
- serializer
- base
- util
- org/apache/flink
- core/fs
- runtime/executiongraph
- streaming/api
- functions/async
- graph
- table/factories
- resources
- scala/org/apache/flink/table/planner/plan/nodes/common
- test/java/com/dtstack/chunjun
- config
- conf
- converter
- dirty
- consumer
- mock
- utils
- interceptor
- lookup
- metrics
- mock
- security
- sink
- format
- source
- format
- typeutil
- serializer
- base
- util
- chunjun-ddl
- chunjun-ddl-base
- src/main/java/com/dtstack/chunjun/ddl/parse
- type
- util
- chunjun-ddl-mysql
- src
- main/java/com/dtstack/chunjun/ddl/convent/mysql
- util
- test/java/com/dtstack/chunjun/ddl/convent
- chunjun-ddl-oracle
- src/main
- codegen
- includes
- java/com/dtstack/chunjun/ddl
- convent/oracle/parse
- convert/oracle
- parse
- type
- util
- chunjun-dirty
- chunjun-dirty-log
- src/main/java/com/dtstack/chunjun/dirty/log
- chunjun-dirty-mysql
- src/main/java/com/dtstack/chunjun/dirty/mysql
- chunjun-docker
- chunjun-e2e
- src/test
- java/com/dtstack/chunjun/connector
- containers/flink
- test
- standalone
- emqx
- ftp
- mysql/sync
- oracle/sync
- postgre/sync
- utils
- resources/docker
- emqx
- flink/standalone
- mysql
- postgre
- chunjun-examples/sql/nebula
- chunjun-formats
- chunjun-protobuf
- src
- main/java/com/dtstack/chunjun/format/protobuf
- deserialize
- serialize
- util
- test/java/com/dtstack/chunjun/format/protobuf/test
- chunjun-local-test
- src/main
- java/com/dtstack/chunjun/local/test
- resources
- task
- chunjun-metrics
- chunjun-metrics-mysql
- src/main/java/com/dtstack/chunjun/metrics/mysql
- chunjun-metrics-prometheus
- src/main/java/com/dtstack/chunjun/metrics/prometheus
- chunjun-metrics-rdb
- src/main/java/com/dtstack/chunjun/metrics/rdb
- chunjun-restore
- chunjun-restore-common
- chunjun-restore-mysql
- src/main/java/com/dtstack/chunjun/restore/mysql
- docs_zh
- ChunJun拓展数据格式
- ChunJun连接器
- binlog
- clickhouse
- db2
- dm
- doris
- elasticsearch
- ftp
- gbase
- greenplum
- hbase
- hdfs
- hive
- influxdb
- kafka
- kingbase
- kudu
- logminer
- mongodb
- mysql
- oceanbasecdc
- oracle
- pgwal
- postgresql
- rabbitmq
- redis
- rocketmq
- s3
- saphana
- sqlservercdc
- sqlserver
- starrocks
- sybase
- 开发者指南
- 拓展功能
- website
- githubInfo
- plugins/json-content
- public
- icons
- page-data
- 404.html
- blogs
- dev-404-page
- documents
- 1b353f9e-a434-50e5-bf3b-47e3ea51e808
- 5bed52d4-4216-529d-9f56-0b00e2f2f126
- 608e954e-8af3-5853-ac42-d86447b4d9a0
- 7a8f3b7e-4fea-5ec3-bb8f-d3fce2ca0fd7
- binlog-source
- c1b9081e-94fb-568e-9fd4-9f43308d1d1b
- clickhouse-sink
- contribution
- db67bfa8-2060-581d-b9bd-9c1ff1c22ae8
- f56e6cbb-9ce1-5520-b121-de0a1f687954
- generalconfig
- kerberos
- prometheus
- questions
- quickstart
- statistics
- download
- examples
- 5e1f992d-2e11-5435-9c26-e3c8a71df04d
- index
- sq/d
- ~partytown
- debug
- src
- assets
- img
- sass
- svg
- components
- AppBannner
- AppCards
- AppContainer
- AppCustomers
- AppDrawer
- AppGithubMember
- AppHeader
- AppInteract
- image
- AppMedium
- AppShowCase
- Context
- LInk
- documentsMenu
- images
- jsonMenu
- space
- sqlMenu
- font
- images
- doc
- LogMiner
- SqlserverCDC
- contribute
- dirty
- incremental
- pr
- quickstart
- restore
- tutorial
- pages
- documents
- examples
- json
- sql
- styles
- img
- templates
- util
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,787 files changed
+24022
-149708
lines changedThis file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| 54 | + | |
| 55 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
120 | 120 | | |
121 | 121 | | |
122 | 122 | | |
123 | | - | |
| 123 | + | |
124 | 124 | | |
125 | 125 | | |
126 | 126 | | |
| |||
203 | 203 | | |
204 | 204 | | |
205 | 205 | | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
206 | 210 | | |
207 | 211 | | |
208 | 212 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
143 | 143 | | |
144 | 144 | | |
145 | 145 | | |
146 | | - | |
| 146 | + | |
147 | 147 | | |
148 | 148 | | |
149 | 149 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
28 | | - | |
| 27 | + | |
29 | 28 | | |
30 | 29 | | |
31 | 30 | | |
| |||
36 | 35 | | |
37 | 36 | | |
38 | 37 | | |
39 | | - | |
| 38 | + | |
40 | 39 | | |
41 | 40 | | |
42 | 41 | | |
| |||
82 | 81 | | |
83 | 82 | | |
84 | 83 | | |
85 | | - | |
86 | | - | |
87 | | - | |
88 | | - | |
89 | | - | |
90 | | - | |
91 | | - | |
92 | | - | |
93 | | - | |
94 | | - | |
95 | 84 | | |
96 | 85 | | |
97 | 86 | | |
| |||
This file was deleted.
0 commit comments