File tree Expand file tree Collapse file tree 6 files changed +869
-0
lines changed
Expand file tree Collapse file tree 6 files changed +869
-0
lines changed Original file line number Diff line number Diff line change @@ -52,6 +52,7 @@ The following databases are currently supported:
5252| | Phoenix | [ doc] ( docs/offline/reader/phoenixreader.md ) | [ doc] ( docs/offline/writer/phoenixwriter.md ) |
5353| | 达梦 | [ doc] ( docs/offline/reader/dmreader.md ) | [ doc] ( docs/offline/writer/dmwriter.md ) |
5454| | Greenplum | [ doc] ( docs/offline/reader/greenplumreader.md ) | [ doc] ( docs/offline/writer/greenplumwriter.md ) |
55+ | | KingBase | [ doc] ( docs/offline/reader/kingbasereader.md ) | [ doc] ( docs/offline/writer/kingbasewriter.md ) |
5556| | Cassandra | [ doc] ( docs/offline/reader/cassandrareader.md ) | [ doc] ( docs/offline/writer/cassandrawriter.md ) |
5657| | ODPS | [ doc] ( docs/offline/reader/odpsreader.md ) | [ doc] ( docs/offline/writer/odpswriter.md ) |
5758| | HBase | [ doc] ( docs/offline/reader/hbasereader.md ) | [ doc] ( docs/offline/writer/hbasewriter.md ) |
Original file line number Diff line number Diff line change @@ -63,6 +63,7 @@ FlinkX目前支持下面这些数据库:
6363| | Phoenix | [ doc] ( docs/offline/reader/phoenixreader.md ) | [ doc] ( docs/offline/writer/phoenixwriter.md ) |
6464| | 达梦 | [ doc] ( docs/offline/reader/dmreader.md ) | [ doc] ( docs/offline/writer/dmwriter.md ) |
6565| | Greenplum | [ doc] ( docs/offline/reader/greenplumreader.md ) | [ doc] ( docs/offline/writer/greenplumwriter.md ) |
66+ | | KingBase | [ doc] ( docs/offline/reader/kingbasereader.md ) | [ doc] ( docs/offline/writer/kingbasewriter.md ) |
6667| | Cassandra | [ doc] ( docs/offline/reader/cassandrareader.md ) | [ doc] ( docs/offline/writer/cassandrawriter.md ) |
6768| | ODPS | [ doc] ( docs/offline/reader/odpsreader.md ) | [ doc] ( docs/offline/writer/odpswriter.md ) |
6869| | HBase | [ doc] ( docs/offline/reader/hbasereader.md ) | [ doc] ( docs/offline/writer/hbasewriter.md ) |
Original file line number Diff line number Diff line change 1+ {
2+ "job" : {
3+ "content" : [
4+ {
5+ "reader" : {
6+ "parameter" : {
7+ "username" : " dtstack" ,
8+ "password" : " abc123" ,
9+ "connection" : [{
10+ "jdbcUrl" : [" jdbc:kingbase8://localhost:54321/test" ],
11+ "table" : [" kudu" ],
12+ "schema" :" test"
13+ }],
14+ "column" : [" *" ],
15+ "customSql" : " " ,
16+ "where" : " id < 100" ,
17+ "splitPk" : " " ,
18+ "queryTimeOut" : 1000 ,
19+ "requestAccumulatorInterval" : 2
20+ },
21+ "name" : " kingbasereader"
22+ },
23+ "writer" : {
24+ "name" : " streamwriter" ,
25+ "parameter" : {
26+ "print" : true
27+ }
28+ }
29+ }
30+ ],
31+ "setting" : {
32+ "speed" : {
33+ "channel" : 1 ,
34+ "bytes" : 0
35+ },
36+ "errorLimit" : {
37+ "record" : 100
38+ },
39+ "restore" : {
40+ "maxRowNumForCheckpoint" : 0 ,
41+ "isRestore" : false ,
42+ "restoreColumnName" : " " ,
43+ "restoreColumnIndex" : 0
44+ },
45+ "log" : {
46+ "isLogger" : false ,
47+ "level" : " debug" ,
48+ "path" : " " ,
49+ "pattern" :" "
50+ }
51+ }
52+ }
53+ }
Original file line number Diff line number Diff line change 1+ {
2+ "job" : {
3+ "content" : [{
4+ "reader" : {
5+ "parameter" : {
6+ "sliceRecordCount" : [" 100" ],
7+ "column" : [
8+ {
9+ "name" : " id" ,
10+ "type" : " int"
11+ },
12+ {
13+ "name" : " user_id" ,
14+ "type" : " int"
15+ },
16+ {
17+ "name" :" name" ,
18+ "type" :" string"
19+ }
20+ ]
21+ },
22+ "name" : " streamreader"
23+ },
24+ "writer" : {
25+ "name" : " kingbasewriter" ,
26+ "parameter" : {
27+ "connection" : [{
28+ "jdbcUrl" : " jdbc:kingbase8://localhost:54321/test" ,
29+ "table" : [
30+ " tableTest"
31+ ],
32+ "schema" :" test"
33+ }],
34+ "username" : " username" ,
35+ "password" : " password" ,
36+ "column" : [
37+ {
38+ "name" : " id" ,
39+ "type" : " BIGINT"
40+ },
41+ {
42+ "name" : " user_id" ,
43+ "type" : " BIGINT"
44+ },
45+ {
46+ "name" : " name" ,
47+ "type" : " varchar"
48+ }],
49+ "writeMode" : " insert" ,
50+ "batchSize" : 1024 ,
51+ "preSql" : [],
52+ "postSql" : []
53+ }
54+ }
55+ }],
56+ "setting" : {
57+ "speed" : {
58+ "channel" : 1 ,
59+ "bytes" : 0
60+ },
61+ "errorLimit" : {
62+ "record" : 100
63+ }
64+ }
65+ }
66+ }
You can’t perform that action at this time.
0 commit comments