Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add ranking config in exchange examples #1407

Merged
merged 1 commit into from
Jan 18, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -242,6 +242,9 @@
field:dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的数据条数。
batch: 256

Expand Down Expand Up @@ -269,6 +272,10 @@
target: {
field:teamid
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -264,6 +264,9 @@ ROW COLUMN+CELL
field:dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的数据条数。
batch: 256

Expand Down Expand Up @@ -293,6 +296,9 @@ ROW COLUMN+CELL
field:teamid
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -296,6 +296,9 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve"
field: dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的最大数据条数。
batch: 256

Expand All @@ -319,6 +322,10 @@ scala> sql("select playerid, teamid, start_year, end_year from basketball.serve"
target: {
field: teamid
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -217,6 +217,9 @@
field:dstPersonId
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的数据条数。
batch: 10

Expand Down Expand Up @@ -247,6 +250,9 @@
field:teamId
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 10
partition: 10
interval.seconds: 10
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -264,6 +264,9 @@
field: dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# Spark 分区数量
partition:10

Expand Down Expand Up @@ -294,6 +297,10 @@
target:{
field: teamid
}

# 指定一个列作为 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 @@ mysql> desc serve;
field: dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的数据条数。
batch: 256

Expand Down Expand Up @@ -307,6 +310,10 @@ mysql> desc serve;
target: {
field: teamid
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 256
partition: 32
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -229,6 +229,9 @@
field:dst_player
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

# 单批次写入 Nebula Graph 的数据条数。
batch: 10

Expand Down Expand Up @@ -262,6 +265,9 @@
field:teamid
}

# 指定一个列作为 rank 的源(可选)。
#ranking: rank

batch: 10
partition: 10
interval.seconds: 10
Expand Down