Skip to content

Commit

Permalink
[Chore] Format the.conf file using the same style (apache#4830)
Browse files Browse the repository at this point in the history
  • Loading branch information
zhilinli123 authored and EricJoy2048 committed Jul 11, 2023
1 parent fc4cc6a commit 887ad24
Show file tree
Hide file tree
Showing 51 changed files with 1,200 additions and 1,200 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,10 +44,10 @@ source {

transform {
Filter {
source_table_name = "fake"
result_table_name = "fake1"
fields = ["name", "age"]
}
source_table_name = "fake"
result_table_name = "fake1"
fields = ["name", "age"]
}
}

sink {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,15 +23,15 @@ env {

source {
# This is a example source plugin **only for test and demonstrate the feature source plugin**
Cassandra {
host = "cassandra:9042"
username = ""
password = ""
datacenter = "datacenter1"
keyspace = "test"
cql = "select * from source_table"
result_table_name = "source_table"
}
Cassandra {
host = "cassandra:9042"
username = ""
password = ""
datacenter = "datacenter1"
keyspace = "test"
cql = "select * from source_table"
result_table_name = "source_table"
}
}

transform {
Expand All @@ -48,5 +48,5 @@ sink {
keyspace = "test"
async_write = "true"
table = "sink_table"
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -41,16 +41,16 @@ transform {

sink {
jdbc {
source_table_name = "customers_mysql_cdc"
url = "jdbc:mysql://mysql_cdc_e2e:3306/mysql_cdc"
driver = "com.mysql.cj.jdbc.Driver"
user = "st_user"
password = "seatunnel"
source_table_name = "customers_mysql_cdc"
url = "jdbc:mysql://mysql_cdc_e2e:3306/mysql_cdc"
driver = "com.mysql.cj.jdbc.Driver"
user = "st_user"
password = "seatunnel"

generate_sink_sql = true
# You need to configure both database and table
database = mysql_cdc
table = mysql_cdc_e2e_sink_table
primary_keys = ["id"]
generate_sink_sql = true
# You need to configure both database and table
database = mysql_cdc
table = mysql_cdc_e2e_sink_table
primary_keys = ["id"]
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -42,18 +42,18 @@ transform {

sink {
console {
source_table_name = "customers"
source_table_name = "customers"
}
Jdbc {
source_table_name = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
database = ""
table = "column_type_test.dbo.full_types_sink"
batch_size = 1
primary_keys = ["id"]
}
source_table_name = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
database = ""
table = "column_type_test.dbo.full_types_sink"
batch_size = 1
primary_keys = ["id"]
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,63 +24,63 @@ env {
}

source {
FakeSource {
schema = {
fields {
pk_id = bigint
name = string
score = int
}
}
rows = [
{
kind = INSERT
fields = [1, "A", 100]
},
{
kind = INSERT
fields = [2, "B", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
}
{
kind = UPDATE_BEFORE
fields = [1, "A", 100]
},
{
kind = UPDATE_AFTER
fields = [1, "A_1", 100]
},
{
kind = DELETE
fields = [2, "B", 100]
}
]
FakeSource {
schema = {
fields {
pk_id = bigint
name = string
score = int
}
}
rows = [
{
kind = INSERT
fields = [1, "A", 100]
},
{
kind = INSERT
fields = [2, "B", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
}
{
kind = UPDATE_BEFORE
fields = [1, "A", 100]
},
{
kind = UPDATE_AFTER
fields = [1, "A_1", 100]
},
{
kind = DELETE
fields = [2, "B", 100]
}
]
}
}

sink {
Clickhouse {
host = "clickhouse:8123"
database = "default"
table = "sink_table"
username = "default"
password = ""
Clickhouse {
host = "clickhouse:8123"
database = "default"
table = "sink_table"
username = "default"
password = ""

primary_key = "pk_id"
}
primary_key = "pk_id"
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,64 +24,64 @@ env {
}

source {
FakeSource {
schema = {
fields {
pk_id = bigint
name = string
score = int
}
}
rows = [
{
kind = INSERT
fields = [1, "A", 100]
},
{
kind = INSERT
fields = [2, "B", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
}
{
kind = UPDATE_BEFORE
fields = [1, "A", 100]
},
{
kind = UPDATE_AFTER
fields = [1, "A_1", 100]
},
{
kind = DELETE
fields = [2, "B", 100]
}
]
FakeSource {
schema = {
fields {
pk_id = bigint
name = string
score = int
}
}
rows = [
{
kind = INSERT
fields = [1, "A", 100]
},
{
kind = INSERT
fields = [2, "B", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
},
{
kind = INSERT
fields = [3, "C", 100]
}
{
kind = UPDATE_BEFORE
fields = [1, "A", 100]
},
{
kind = UPDATE_AFTER
fields = [1, "A_1", 100]
},
{
kind = DELETE
fields = [2, "B", 100]
}
]
}
}

sink {
Clickhouse {
host = "clickhouse:8123"
database = "default"
table = "sink_table"
username = "default"
password = ""
Clickhouse {
host = "clickhouse:8123"
database = "default"
table = "sink_table"
username = "default"
password = ""

primary_key = "pk_id"
allow_experimental_lightweight_delete = true
}
primary_key = "pk_id"
allow_experimental_lightweight_delete = true
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,14 +26,14 @@ env {

source {
# This is a example source plugin **only for test and demonstrate the feature source plugin**
Clickhouse {
host = "clickhouse:8123"
database = "default"
sql = "select * from source_table"
username = "default"
password = ""
result_table_name = "source_table"
}
Clickhouse {
host = "clickhouse:8123"
database = "default"
sql = "select * from source_table"
username = "default"
password = ""
result_table_name = "source_table"
}
# If you would like to get more information about how to configure seatunnel and see full list of source plugins,
# please go to https://seatunnel.apache.org/docs/connector-v2/source/ClickhouseSource
}
Expand All @@ -45,7 +45,7 @@ sink {
table = "sink_table"
username = "default"
password = ""
}
}

# If you would like to get more information about how to configure seatunnel and see full list of sink plugins,
# please go to https://seatunnel.apache.org/docs/connector-v2/sink
Expand Down
Loading

0 comments on commit 887ad24

Please sign in to comment.