Skip to content

Commit

Permalink
Add ranking config in exchange examples (#1050)
Browse files Browse the repository at this point in the history
  • Loading branch information
randomJoe211 committed Jan 18, 2022
1 parent f678778 commit fa0f612
Show file tree
Hide file tree
Showing 10 changed files with 41 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -238,6 +238,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down Expand Up @@ -265,6 +268,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
target: {
field:teamid
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -267,6 +267,8 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down Expand Up @@ -297,6 +299,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:teamid
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -298,6 +298,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand All @@ -321,6 +324,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
target: {
field: teamid
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -303,7 +303,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
}
# (optionally) Specify a column as the source of the rank.
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
Expand Down Expand Up @@ -348,11 +348,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst
}
# (optionally) Specify a column as the source of the rank.
# (Optional) Specify a column as the source of the rank.
#ranking: _c5
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -227,6 +227,8 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:offset
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 10
Expand Down Expand Up @@ -258,6 +260,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:value
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
batch: 10
partition: 10
interval.seconds: 10
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -261,6 +261,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of Spark partitions.
partition:10
Expand Down Expand Up @@ -291,6 +294,10 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
target:{
field: teamid
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
partition:10
batch:10
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -277,6 +277,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
Expand Down Expand Up @@ -319,7 +318,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
# (Optional) Specify a column as the source of the rank.
#ranking: _c5
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,6 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
Expand Down Expand Up @@ -316,11 +315,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field: dst
}
# (Optional) Specify a column as the source of the rank.
#ranking: _c5
# The number of data written to Nebula Graph in a single batch.
batch: 256
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -229,11 +229,12 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:src_player
}
target:{
field:dst_player
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
# The number of data written to Nebula Graph in a single batch.
batch: 10
Expand Down Expand Up @@ -268,6 +269,9 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
field:teamid
}
# (Optional) Specify a column as the source of the rank.
#ranking: rank
batch: 10
partition: 10
interval.seconds: 10
Expand Down

0 comments on commit fa0f612

Please sign in to comment.