[Feature][Core] Rename result_table_name/source_table_name to plugin_input/plugin_output (#8072)

Author: hailin0

config/v2.batch.config.template

@@ -29,7 +29,7 @@ source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
   FakeSource {
     parallelism = 2
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 16
     schema = {
       fields {

config/v2.streaming.conf.template

@@ -29,7 +29,7 @@ source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
   FakeSource {
     parallelism = 2
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 16
     schema = {
       fields {

docs/en/concept/config.md

@@ -19,6 +19,12 @@ config directory.
 
 The config file is similar to the below one:
 
+:::warn
+
+The old configuration name `source_table_name`/`result_table_name` is deprecated, please migrate to the new name `plugin_input`/`plugin_output` as soon as possible.
+
+:::
+
 ### hocon
 
 ```hocon
@@ -28,7 +34,7 @@ env {
 
 source {
   FakeSource {
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 100
     schema = {
       fields {
@@ -42,8 +48,8 @@ source {
 
 transform {
   Filter {
-    source_table_name = "fake"
-    result_table_name = "fake1"
+    plugin_input = "fake"
+    plugin_output = "fake1"
     fields = [name, card]
   }
 }
@@ -56,7 +62,7 @@ sink {
     fields = ["name", "card"]
     username = "default"
     password = ""
-    source_table_name = "fake1"
+    plugin_input = "fake1"
   }
 }
 ```
@@ -80,7 +86,7 @@ Source is used to define where SeaTunnel needs to fetch data, and use the fetche
 Multiple sources can be defined at the same time. The supported source can be found
 in [Source of SeaTunnel](../connector-v2/source). Each source has its own specific parameters to define how to
 fetch data, and SeaTunnel also extracts the parameters that each source will use, such as
-the `result_table_name` parameter, which is used to specify the name of the data generated by the current
+the `plugin_output` parameter, which is used to specify the name of the data generated by the current
 source, which is convenient for follow-up used by other modules.
 
 ### transform
@@ -96,7 +102,7 @@ env {
 
 source {
   FakeSource {
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 100
     schema = {
       fields {
@@ -116,7 +122,7 @@ sink {
     fields = ["name", "age", "card"]
     username = "default"
     password = ""
-    source_table_name = "fake"
+    plugin_input = "fake"
   }
 }
 ```
@@ -134,11 +140,11 @@ and efficiently. Sink and source are very similar, but the difference is reading
 ### Other Information
 
 You will find that when multiple sources and multiple sinks are defined, which data is read by each sink, and
-which is the data read by each transform? We introduce two key configurations called `result_table_name` and
-`source_table_name`. Each source module will be configured with a `result_table_name` to indicate the name of the
-data source generated by the data source, and other transform and sink modules can use `source_table_name` to
+which is the data read by each transform? We introduce two key configurations called `plugin_output` and
+`plugin_input`. Each source module will be configured with a `plugin_output` to indicate the name of the
+data source generated by the data source, and other transform and sink modules can use `plugin_input` to
 refer to the corresponding data source name, indicating that I want to read the data for processing. Then
-transform, as an intermediate processing module, can use both `result_table_name` and `source_table_name`
+transform, as an intermediate processing module, can use both `plugin_output` and `plugin_input`
 configurations at the same time. But you will find that in the above example config, not every module is
 configured with these two parameters, because in SeaTunnel, there is a default convention, if these two
 parameters are not configured, then the generated data from the last module of the previous node will be used.
@@ -170,7 +176,7 @@ Before writing the config file, please make sure that the name of the config fil
   "source": [
     {
       "plugin_name": "FakeSource",
-      "result_table_name": "fake",
+      "plugin_output": "fake",
       "row.num": 100,
       "schema": {
         "fields": {
@@ -184,8 +190,8 @@ Before writing the config file, please make sure that the name of the config fil
   "transform": [
     {
       "plugin_name": "Filter",
-      "source_table_name": "fake",
-      "result_table_name": "fake1",
+      "plugin_input": "fake",
+      "plugin_output": "fake1",
       "fields": ["name", "card"]
     }
   ],
@@ -198,7 +204,7 @@ Before writing the config file, please make sure that the name of the config fil
       "fields": ["name", "card"],
       "username": "default",
       "password": "",
-      "source_table_name": "fake1"
+      "plugin_input": "fake1"
     }
   ]
 }
@@ -234,7 +240,7 @@ env {
 
 source {
   FakeSource {
-    result_table_name = "${resName:fake_test}_table"
+    plugin_output = "${resName:fake_test}_table"
     row.num = "${rowNum:50}"
     string.template = ${strTemplate}
     int.template = [20, 21]
@@ -249,16 +255,16 @@ source {
 
 transform {
     sql {
-      source_table_name = "${resName:fake_test}_table"
-      result_table_name = "sql"
+      plugin_input = "${resName:fake_test}_table"
+      plugin_output = "sql"
       query = "select * from ${resName:fake_test}_table where name = '${nameVal}' "
     }
 
 }
 
 sink {
   Console {
-     source_table_name = "sql"
+     plugin_input = "sql"
      username = ${username}
      password = ${password}
   }
@@ -291,7 +297,7 @@ env {
 
 source {
   FakeSource {
-    result_table_name = "fake_test_table"
+    plugin_output = "fake_test_table"
     row.num = 50
     string.template = ['abc','d~f','hi']
     int.template = [20, 21]
@@ -306,16 +312,16 @@ source {
 
 transform {
     sql {
-      source_table_name = "fake_test_table"
-      result_table_name = "sql"
+      plugin_input = "fake_test_table"
+      plugin_output = "sql"
       query = "select * from fake_test_table where name = 'abc' "
     }
 
 }
 
 sink {
   Console {
-     source_table_name = "sql"
+     plugin_input = "sql"
      username = "seatunnel=2.3.1"
      password = "$a^b%c.d~e0*9("
     }

docs/en/concept/schema-evolution.md

@@ -75,7 +75,7 @@ env {
 source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
   Oracle-CDC {
-    result_table_name = "customers"
+    plugin_output = "customers"
     username = "dbzuser"
     password = "dbz"
     database-names = ["ORCLCDB"]
@@ -93,7 +93,7 @@ source {
 
 sink {
     Jdbc {
-      source_table_name = "customers"
+      plugin_input = "customers"
       driver = "oracle.jdbc.driver.OracleDriver"
       url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
       user = "dbzuser"
@@ -120,7 +120,7 @@ env {
 source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
   Oracle-CDC {
-    result_table_name = "customers"
+    plugin_output = "customers"
     username = "dbzuser"
     password = "dbz"
     database-names = ["ORCLCDB"]
@@ -138,7 +138,7 @@ source {
 
 sink {
   jdbc {
-    source_table_name = "customers"
+    plugin_input = "customers"
     url = "jdbc:mysql://oracle-host:3306/oracle_sink"
     driver = "com.mysql.cj.jdbc.Driver"
     user = "st_user_sink"

docs/en/concept/schema-feature.md

@@ -180,7 +180,7 @@ constraintKeys = [
 source {
   FakeSource {
     parallelism = 2
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 16
     schema {
         table = "FakeDatabase.FakeTable"
@@ -234,7 +234,7 @@ If you only need to define the column, you can use fields to define the column,
 source {
   FakeSource {
     parallelism = 2
-    result_table_name = "fake"
+    plugin_output = "fake"
     row.num = 16
     schema = {
       fields {

docs/en/connector-v2/Config-Encryption-Decryption.md

@@ -42,7 +42,7 @@ Next, I'll show how to quickly use SeaTunnel's own `base64` encryption:
 
    source {
      MySQL-CDC {
-       result_table_name = "fake"
+       plugin_output = "fake"
        parallelism = 1
        server-id = 5656
        port = 56725
@@ -96,7 +96,7 @@ Next, I'll show how to quickly use SeaTunnel's own `base64` encryption:
                "port" : 56725,
                "database-name" : "inventory_vwyw0n",
                "parallelism" : 1,
-               "result_table_name" : "fake",
+               "plugin_output" : "fake",
                "table-name" : "products",
                "plugin_name" : "MySQL-CDC",
                "server-id" : 5656,

docs/en/connector-v2/formats/avro.md

@@ -51,7 +51,7 @@ source {
         }
       }
     }
-    result_table_name = "fake"
+    plugin_output = "fake"
   }
 }
 
@@ -76,7 +76,7 @@ source {
   Kafka {
     bootstrap.servers = "kafkaCluster:9092"
     topic = "test_avro_topic"
-    result_table_name = "kafka_table"
+    plugin_output = "kafka_table"
     start_mode = "earliest"
     format = avro
     format_error_handle_way = skip
@@ -104,7 +104,7 @@ source {
 
 sink {
   Console {
-    source_table_name = "kafka_table"
+    plugin_input = "kafka_table"
   }
 }
 ```

docs/en/connector-v2/formats/canal-json.md

@@ -85,7 +85,7 @@ source {
   Kafka {
     bootstrap.servers = "kafkaCluster:9092"
     topic = "products_binlog"
-    result_table_name = "kafka_name"
+    plugin_output = "kafka_name"
     start_mode = earliest
     schema = {
       fields {

docs/en/connector-v2/formats/cdc-compatible-debezium-json.md

@@ -17,7 +17,7 @@ env {
 
 source {
   MySQL-CDC {
-    result_table_name = "table1"
+    plugin_output = "table1"
 
     base-url="jdbc:mysql://localhost:3306/test"
     "startup.mode"=INITIAL
@@ -43,7 +43,7 @@ source {
 
 sink {
   Kafka {
-    source_table_name = "table1"
+    plugin_input = "table1"
 
     bootstrap.servers = "localhost:9092"
 

docs/en/connector-v2/formats/debezium-json.md

@@ -84,7 +84,7 @@ source {
   Kafka {
     bootstrap.servers = "kafkaCluster:9092"
     topic = "products_binlog"
-    result_table_name = "kafka_name"
+    plugin_output = "kafka_name"
     start_mode = earliest
     schema = {
       fields {

docs/en/connector-v2/formats/kafka-compatible-kafkaconnect-json.md

@@ -16,7 +16,7 @@ source {
   Kafka {
     bootstrap.servers = "localhost:9092"
     topic = "jdbc_source_record"
-    result_table_name = "kafka_table"
+    plugin_output = "kafka_table"
     start_mode = earliest
     schema = {
       fields {

docs/en/connector-v2/formats/maxwell-json.md

@@ -62,7 +62,7 @@ source {
   Kafka {
     bootstrap.servers = "kafkaCluster:9092"
     topic = "products_binlog"
-    result_table_name = "kafka_name"
+    plugin_output = "kafka_name"
     start_mode = earliest
     schema = {
       fields {

docs/en/connector-v2/formats/ogg-json.md

@@ -66,7 +66,7 @@ source {
   Kafka {
     bootstrap.servers = "127.0.0.1:9092"
     topic = "ogg"
-    result_table_name = "kafka_name"
+    plugin_output = "kafka_name"
     start_mode = earliest
     schema = {
       fields {

docs/en/connector-v2/formats/protobuf.md

@@ -17,7 +17,7 @@ env {
 source {
    FakeSource {
       parallelism = 1
-      result_table_name = "fake"
+      plugin_output = "fake"
       row.num = 16
       schema = {
         fields {
@@ -151,13 +151,13 @@ source {
         }
         bootstrap.servers = "kafkaCluster:9092"
         start_mode = "earliest"
-        result_table_name = "kafka_table"
+        plugin_output = "kafka_table"
     }
 }
 
 sink {
   Console {
-    source_table_name = "kafka_table"
+    plugin_input = "kafka_table"
   }
 }
 ```