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.

Sign up for GitHub

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

update connector and exchange #2551

Merged
merged 2 commits into from
Apr 28, 2024
Merged

update connector and exchange #2551

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
cdf1630
update connector and exchange
cooper-lzy Apr 28, 2024
4dd9435
exchange supports filter (#467)
cooper-lzy Apr 28, 2024
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
1 change: 1 addition & 0 deletions docs-2.0-en/connector/nebula-flink-connector.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ The correspondence between the NebulaGraph Flink Connector version and the Nebul
| Flink Connector version | NebulaGraph version |
|:----------|:-----------|
| 3.0-SNAPSHOT | nightly |
| 3.8.0 | 3.x.x |
| 3.5.0 | 3.x.x |
| 3.3.0 | 3.x.x |
| 3.0.0 | 3.x.x |
Expand Down
9 changes: 9 additions & 0 deletions docs-2.0-en/connector/nebula-spark-connector.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,9 @@ The correspondence between the NebulaGraph Spark Connector version, the NebulaGr
|nebula-spark-connector_3.0-3.0-SNAPSHOT.jar| nightly| 3.x|
|nebula-spark-connector_2.2-3.0-SNAPSHOT.jar| nightly| 2.2.x|
|nebula-spark-connector-3.0-SNAPSHOT.jar| nightly| 2.4.x|
|nebula-spark-connector_3.0-3.8.0.jar| 3.x | 3.x |
|nebula-spark-connector_2.2-3.8.0.jar| 3.x | 2.2.x |
|nebula-spark-connector-3.8.0.jar | 3.x | 2.4.x |
|nebula-spark-connector_3.0-3.6.0.jar| 3.x | 3.x |
|nebula-spark-connector_2.2-3.6.0.jar| 3.x | 2.2.x |
|nebula-spark-connector-3.6.0.jar | 3.x | 2.4.x |
Expand Down Expand Up @@ -148,6 +151,8 @@ val config = NebulaConnectionConfig

val nebulaReadVertexConfig: ReadNebulaConfig = ReadNebulaConfig
.builder()
.withUser("root")
.withPasswd("nebula")
.withSpace("test")
.withLabel("person")
.withNoColumn(false)
Expand All @@ -159,6 +164,8 @@ val vertex = spark.read.nebula(config, nebulaReadVertexConfig).loadVerticesToDF(

val nebulaReadEdgeConfig: ReadNebulaConfig = ReadNebulaConfig
.builder()
.withUser("root")
.withPasswd("nebula")
.withSpace("test")
.withLabel("knows")
.withNoColumn(false)
Expand All @@ -182,6 +189,8 @@ val edge = spark.read.nebula(config, nebulaReadEdgeConfig).loadEdgesToDF()

|Parameter|Required|Description|
|:---|:---|:---|
|`withUser` |No| NebulaGraph username. This parameter is required when the Storage services require authentication. This parameter is only supported in NebulaGraph Enterprise Edition. |
|`withPasswd` |No| The password for the NebulaGraph username. This parameter is required when the Storage services require authentication. This parameter is only supported in NebulaGraph Enterprise Edition. |
|`withSpace` |Yes| NebulaGraph space name. |
|`withLabel` |Yes| The Tag or Edge type name within the NebulaGraph space. |
|`withNoColumn` |No| Whether the property is not read. The default value is `false`, read property. If the value is `true`, the property is not read, the `withReturnCols` configuration is invalid. |
Expand Down
3 changes: 2 additions & 1 deletion docs-2.0-zh/connector/nebula-flink-connector.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,8 @@ NebulaGraph Flink Connector 和{{nebula.name}}内核版本对应关系如下。

| Flink Connector 版本 | {{nebula.name}}版本 |
|:----------|:-----------|
| 3.0-SNAPSHOT | nightly |
| 3.0-SNAPSHOT | nightly |
| 3.8.0 | 3.x.x |
| 3.5.0 | 3.x.x |
| 3.3.0 | 3.x.x |
| 3.0.0 | 3.x.x |
Expand Down
9 changes: 9 additions & 0 deletions docs-2.0-zh/connector/nebula-spark-connector.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,9 @@ NebulaGraph Spark Connector、 {{nebula.name}} 内核版本和 Spark 版本对
|nebula-spark-connector_3.0-3.0-SNAPSHOT.jar| nightly| 3.x|
|nebula-spark-connector_2.2-3.0-SNAPSHOT.jar| nightly| 2.2.x|
|nebula-spark-connector-3.0-SNAPSHOT.jar| nightly| 2.4.x|
|nebula-spark-connector_3.0-3.8.0.jar| 3.x | 3.x |
|nebula-spark-connector_2.2-3.8.0.jar| 3.x | 2.2.x |
|nebula-spark-connector-3.8.0.jar | 3.x | 2.4.x |
|nebula-spark-connector_3.0-3.6.0.jar| 3.x | 3.x |
|nebula-spark-connector_2.2-3.6.0.jar| 3.x | 2.2.x |
|nebula-spark-connector-3.6.0.jar | 3.x | 2.4.x |
Expand Down Expand Up @@ -148,6 +151,8 @@ val config = NebulaConnectionConfig

val nebulaReadVertexConfig: ReadNebulaConfig = ReadNebulaConfig
.builder()
.withUser("root")
.withPasswd("nebula")
.withSpace("test")
.withLabel("person")
.withNoColumn(false)
Expand All @@ -159,6 +164,8 @@ val vertex = spark.read.nebula(config, nebulaReadVertexConfig).loadVerticesToDF(

val nebulaReadEdgeConfig: ReadNebulaConfig = ReadNebulaConfig
.builder()
.withUser("root")
.withPasswd("nebula")
.withSpace("test")
.withLabel("knows")
.withNoColumn(false)
Expand All @@ -182,6 +189,8 @@ val edge = spark.read.nebula(config, nebulaReadEdgeConfig).loadEdgesToDF()

|参数|是否必须|说明|
|:---|:---|:---|
|`withUser` |否| {{nebula.name}}用户名。Storage 服务要求身份认证时，需要填写该参数。仅 {{nebula.name}} 企业版支持该参数。 |
|`withPasswd` |否| {{nebula.name}}用户名对应的密码。Storage 服务要求身份认证时，需要填写该参数。仅 {{nebula.name}} 企业版支持该参数。 |
|`withSpace` |是| {{nebula.name}} 图空间名称。 |
|`withLabel` |是| {{nebula.name}} 图空间内的 Tag 或 Edge type 名称。 |
|`withNoColumn` |否| 是否不读取属性。默认值为`false`，表示读取属性。取值为`true`时，表示不读取属性，此时`withReturnCols`配置无效。 |
Expand Down
18 changes: 9 additions & 9 deletions mkdocs.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -288,9 +288,9 @@ extra:
release: 3.9.0
tag: v3.9.0
exchange:
release: 3.7.0
branch: release-3.7
tag: v3.7.0
release: 3.8.0
branch: release-3.8
tag: v3.8.0
importer:
release: 4.1.0
branch: release-4.1
Expand All @@ -300,13 +300,13 @@ extra:
branch: v3.0.0
tag: v3.0.0
sparkconnector:
release: 3.6.0
branch: release-3.6
tag: v3.6.0
release: 3.8.0
branch: release-3.8
tag: v3.8.0
flinkconnector:
release: 3.5.0
branch: release-3.5
tag: v3.5.0
release: 3.8.0
branch: release-3.8
tag: v3.8.0
dockercompose:
release: 3.6.0
branch: release-3.6
Expand Down