Skip to content

Commit

Permalink
Fix code style
Browse files Browse the repository at this point in the history
  • Loading branch information
MonsterChenzhuo committed May 6, 2023
1 parent 005b8b0 commit 5430885
Show file tree
Hide file tree
Showing 5 changed files with 3 additions and 9 deletions.
5 changes: 1 addition & 4 deletions docs/en/connector-v2/sink/MongoDB.md
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,8 @@ Key featuresl
-------------

- [x] [batch](../../concept/connector-v2-features.md)
- [ ] [stream](../../concept/connector-v2-features.md)
- [ ] [exactly-once](../../concept/connector-v2-features.md)
- [x] [column projection](../../concept/connector-v2-features.md)
- [x] [parallelism](../../concept/connector-v2-features.md)
- [x] [support user-defined split](../../concept/connector-v2-features.md)
- [ ] [cdc](../../concept/connector-v2-features.md)

Dependencies
------------
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ public Object apply(BsonValue bsonValue) {
case ARRAY:
return createArrayConverter((ArrayType<?, ?>) type);
case MAP:
MapType mapType = (MapType) type;
MapType<?, ?> mapType = (MapType<?, ?>) type;
return createMapConverter(
mapType.toString(), mapType.getKeyType(), mapType.getValueType());

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,6 @@ source {
}
}


sink {
Console {
source_table_name = "mongodb_table"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ env {

source {
MongoDB {
uri = "mongodb://10.30.238.11:27017/test_db"
uri = "mongodb://e2e_mongodb:27017/test_db"
database = "test_db"
collection = "test_match_op_db"
result_table_name = "mongodb_table"
Expand Down Expand Up @@ -62,7 +62,6 @@ source {
}
}


sink {
Console {
source_table_name = "mongodb_table"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,6 @@ source {
}
}


sink {
Console {
source_table_name = "mongodb_table"
Expand Down

0 comments on commit 5430885

Please sign in to comment.