Commit d315ca8
committed
change mongo flink-cdc source connector change to Source<> type
1 parent d4840eb commit d315ca8
1,027 files changed
Lines changed: 7148 additions & 102 deletions
File tree
- classes
- production
- tis-chunjun-base-plugin
- META-INF/annotations
- com/qlangtech/tis/plugins/incr/flink
- chunjun
- common
- offset
- poll
- script
- sink
- source
- table
- connector
- impl
- tis-datax-common-plugin
- META-INF/annotations
- com/qlangtech/tis
- fullbuild/taskflow
- hive
- hive
- plugin
- aliyun
- datax
- common
- impl
- format/guesstype
- kingbase
- powerjob
- writer
- ds
- tis-datax-executor
- com/qlangtech/tis
- datax
- common
- executor
- join
- logger
- powerjob
- plugin/datax
- grpc
- tis-datax-local-executor-utils/com/qlangtech/tis/datax
- tis-datax-mongodb-plugin
- META-INF/annotations
- com/qlangtech/tis/plugin
- datax
- mongo
- reader
- ds/mangodb
- tis-datax-test-common
- META-INF/services
- com/qlangtech
- plugins/incr/flink/cdc
- tis
- coredefine/module/action
- plugin
- common
- datax
- test
- ds
- oracle
- postgresql
- test
- runtime/module/action
- utils
- util
- tis-flink-cdc-common
- META-INF/annotations
- com/qlangtech/plugins/incr
- debuzium
- flink/cdc
- impl
- valconvert
- tis-flink-cdc-mongdb-plugin
- META-INF/annotations
- com/qlangtech/plugins/incr/flink/cdc/mongdb
- impl
- startup
- updatecomplete
- tis-flink-dependency
- tis-flink-extends-plugin
- tis-flink-extends
- META-INF/services
- com/qlangtech
- plugins/incr/flink
- cdc
- metrics
- tis/realtime
- dto
- source
- org/apache/flink/kubernetes/entrypoint
- tis-incr-test
- com/qlangtech
- plugins/incr/flink
- cdc
- source
- chunjun/doris/sink
- junit
- sink
- tis/plugins/incr/flink/cdc/mysql
- instancedetail
- org/apache/flink/cdc/connectors/mysql/testutils
- tis-k8s-plugin
- META-INF/annotations
- com/qlangtech/tis
- config/k8s/impl
- plugin
- datax
- powerjob
- impl
- coresource
- oms
- serverport
- incr
- k8s
- tis-powerjob-common-plugin
- META-INF/annotations
- com/qlangtech/tis/plugin/datax/powerjob
- impl
- tis-realtime-flink
- META-INF/annotations
- com/qlangtech
- plugins/incr/flink
- cdc
- cluster
- common
- launch
- ckpt
- clustertype
- restart
- statbackend
- tis
- plugins
- flink/client
- util
- incr/flink
- cdc
- impl
- connector
- scripttype
- streamscript
- realtime
- tis-testcontainer-mysql
- com/qlangtech/plugins/incr/flink/slf4j
- docker
- server-gtids
- server
- maria/docker
- server/tis
- org/apache/flink/cdc/connectors
- mariadb
- mysql/testutils
- tis-transformer
- META-INF/annotations
- com/qlangtech/tis/plugin/datax/transformer/impl
- test
- tis-chunjun-base-plugin
- com/qlangtech/tis/plugins/incr/flink/chunjun/sink
- tis-datax-common-plugin
- com/qlangtech/tis
- coredefine/module/action
- plugin/datax
- buildhistory
- common
- tis-datax-executor
- com/qlangtech/tis/datax
- tis-datax-local-executor-utils/com/qlangtech/tis/datax
- tis-datax-mongodb-plugin
- com/qlangtech/tis/plugin
- datax
- mongo
- ds/mangodb
- tis-datax-test-common
- tis-flink-cdc-mongdb-plugin
- com/qlangtech/plugins/incr/flink/cdc/mongdb
- utils
- ddl
- docker/mongodb
- tis-flink-dependency
- com/qlangtech/plugins/incr/flink
- tis-flink-extends
- com/qlangtech/plugins/incr/flink
- tis-k8s-plugin
- com/qlangtech/tis
- config/k8s/impl
- plugin
- datax
- powerjob
- impl
- coresource
- serverport
- incr
- k8s
- tis-realtime-flink
- com/qlangtech
- plugins/incr/flink
- cdc
- cluster
- common
- launch
- ckpt
- tis/plugins/flink/client
- tis-testcontainer-mysql
- org/apache/flink/cdc/connectors/mysql/testutils
- tis-transformer
- com/qlangtech/tis/plugin/datax/transformer/impl
- auto_generate_big_int_idudf
- concat_udf
- copy_val_udf
- j_sonsplitter_udf
- tis-incr
- tis-flink-cdc-common-plugin-shade-4-debezium
- tis-flink-cdc-common
- tis-flink-cdc-mongdb-plugin
- src
- main/java/com/qlangtech/plugins/incr/flink/cdc/mongdb
- impl
- startup
- updatecomplete
- test/java/com/qlangtech/plugins/incr/flink/cdc/mongdb
- tis-flink-extends/src/main/java/com/qlangtech/tis/realtime
- source
- tis-incr-test/src/main/java/com/qlangtech/plugins/incr/flink/cdc
- tis-realtime-flink/src/main/java/com/qlangtech
- plugins/incr/flink/launch
- tis
- plugins/incr/flink/cdc
- realtime
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Binary file not shown.
Lines changed: 14 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
Binary file not shown.
Binary file not shown.
Binary file not shown.
Lines changed: 5 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
Binary file not shown.
0 commit comments