导入 Neo4j 数据 实现方法 示例场景 环境配置 数据集信息 数据库信息 前提条件 操作步骤 步骤 1. 在 Nebula Graph 中构建图数据模式（Schema） 步骤 2. 配置源数据 步骤 3. 修改配置文件 exec 配置说明 tags.vertex 或 edges.vertex 配置说明 check_point_path...

USE 语法 USE 语法 USE <graph_space_name> 在 Nebula Graph 中 USE 语句的作用是选择一个图空间来作为当前的工作图空间。USE 需要一些特定的权限来执行。 当前的图空间会保持默认直至当前会话结束或另一个 USE 被执行。 nebula > USE space1 nebula > ...

Exchange常见问题 编译问题 部分非central仓库的包下载失败，报错Could not resolve dependencies for project xxx 执行问题 Yarn-Cluster模式下如何提交？ 报错method name xxx not found 报NoSuchMethod、MethodNotFound错误（Exc...

自定义 sink (NebulaSink) NebulaSinkFunction NebulaBatchOutputFormat 应用实践 NebulaSink 示例程序 自定义 sink (NebulaSink) Nebula Flink Connector 支持以 DataStream.addSink 的方式将 Flink 数据流写入...

谓词函数 openCypher兼容性 语法 示例 谓词函数 谓词函数只返回true 或false ，通常用于WHERE 子句中。 Nebula Graph支持以下谓词函数。 函数 说明 exists() 如果指定的属性在点、边或映射中存在，则返回true ，否则返回false 。 any() 如果指定的谓词适用于列表中的至少一个元素，则返回t...

DELETE TAG 前提条件 语法 示例 DELETE TAG DELETE TAG 语句可以删除指定点上的指定Tag。 点可以有一个或多个Tag。 如果某个点只有一个Tag，删除这个点上的Tag后，用户就无法访问 这个点，下次Compaction操作时会删除该点，但点上的边仍然存在。 如果某个点有多个Tag，删除其中一个Tag，仍然...

DELETE TAG 前提条件 语法 示例 DELETE TAG DELETE TAG 语句可以删除指定点上的指定Tag。 点可以有一个或多个Tag。 如果某个点只有一个Tag，删除这个点上的Tag后，用户就无法访问 这个点，下次Compaction操作时会删除该点，但点上的边仍然存在。 如果某个点有多个Tag，删除其中一个Tag，仍然...

特殊说明 Catalog Exactly-once 特殊说明 Catalog Flink 1.11.0 之前，如果依赖 Flink 的 source/sink 读写外部数据源时，用户必须手动读取对应数据系统的 Schema（模式）。例如，如果您要读写 Nebula Graph 的数据，则必须先保证明确地知晓 Nebula Graph 中的 Sch...

导入JSON文件数据 数据集 环境配置 前提条件 操作步骤 步骤 1：在Nebula Graph中创建Schema 步骤 2：处理JSON文件 步骤 3. 修改配置文件 步骤 4：向Nebula Graph导入数据 步骤 5：（可选）验证数据 步骤 6：（如有）在Nebula Graph中重建索引 导入JSON文件数据 本文以一个示...

导入JSON文件数据 数据集 环境配置 前提条件 操作步骤 步骤 1：在Nebula Graph中创建Schema 步骤 2：处理JSON文件 步骤 3. 修改配置文件 步骤 4：向Nebula Graph导入数据 步骤 5：（可选）验证数据 步骤 6：（如有）在Nebula Graph中重建索引 导入JSON文件数据 本文以一个示...