Skip to content

Commit

Permalink
[Kudu] [Config] Change Kudu connector name
Browse files Browse the repository at this point in the history
  • Loading branch information
Hisoka-X committed Nov 19, 2022
1 parent da9d90f commit 79185b3
Show file tree
Hide file tree
Showing 5 changed files with 14 additions and 6 deletions.
6 changes: 5 additions & 1 deletion docs/en/connector-v2/sink/Kudu.md
Expand Up @@ -42,7 +42,7 @@ Sink plugin common parameters, please refer to [Sink Common Options](common-opti

```bash

kuduSink {
kudu {
kudu_master = "192.168.88.110:7051"
kudu_table = "studentlyhresultflink"
save_mode="append"
Expand All @@ -58,3 +58,7 @@ Sink plugin common parameters, please refer to [Sink Common Options](common-opti

### 2.3.0-beta 2022-10-20
- [Improve] Kudu Sink Connector Support to upsert row ([2881](https://github.com/apache/incubator-seatunnel/pull/2881))

### Next Version

- Change plugin name from `KuduSink` to `Kudu` [3432](https://github.com/apache/incubator-seatunnel/pull/3432)
6 changes: 5 additions & 1 deletion docs/en/connector-v2/source/Kudu.md
Expand Up @@ -46,7 +46,7 @@ Source plugin common parameters, please refer to [Source Common Options](common-

```hocon
source {
KuduSource {
Kudu {
result_table_name = "studentlyh2"
kudu_master = "192.168.88.110:7051"
kudu_table = "studentlyh2"
Expand All @@ -61,3 +61,7 @@ source {
### 2.2.0-beta 2022-09-26

- Add Kudu Source Connector

### Next Version

- Change plugin name from `KuduSource` to `Kudu` [3432](https://github.com/apache/incubator-seatunnel/pull/3432)
4 changes: 2 additions & 2 deletions plugin-mapping.properties
Expand Up @@ -106,8 +106,8 @@ seatunnel.sink.Clickhouse = connector-clickhouse
seatunnel.sink.ClickhouseFile = connector-clickhouse
seatunnel.source.Jdbc = connector-jdbc
seatunnel.sink.Jdbc = connector-jdbc
seatunnel.source.KuduSource = connector-kudu
seatunnel.sink.KuduSink = connector-kudu
seatunnel.source.Kudu = connector-kudu
seatunnel.sink.Kudu = connector-kudu
seatunnel.sink.EmailSink = connector-email
seatunnel.source.HdfsFile = connector-file-hadoop
seatunnel.sink.HdfsFile = connector-file-hadoop
Expand Down
Expand Up @@ -44,7 +44,7 @@ public class KuduSink extends AbstractSimpleSink<SeaTunnelRow, Void> {

@Override
public String getPluginName() {
return "kuduSink";
return "kudu";
}

@Override
Expand Down
Expand Up @@ -95,7 +95,7 @@ public Serializer<KuduSourceState> getEnumeratorStateSerializer() {

@Override
public String getPluginName() {
return "KuduSource";
return "Kudu";
}

@Override
Expand Down

0 comments on commit 79185b3

Please sign in to comment.