apoc.load.arrow.stream

在 APOC 2025.06 版本中,此过程已被迁移至不受支持的 APOC Extended 库。这意味着如果您使用的是 APOC 2025.06 或更高版本,该过程在 Cypher 25 中将不可用,但仍可在 Cypher 5 中使用。有关更多信息,请参阅 APOC 和 Cypher 版本
详细信息

语法

apoc.load.arrow.stream(source [, config ]) :: (value)

描述

从提供的 Arrow 字节数组中导入 NODE(节点)和 RELATIONSHIP(关系)值。

输入参数

名称

类型

描述

source

BYTEARRAY

要加载的数据。

config

MAP

此值目前未使用。默认值为:{}

返回参数

名称

类型

描述

MAP

从给定文件加载的数据映射。

用法示例

假设一个 Arrow byte[] 包含人员及其属性

test.arrow
name,age,beverage
Selma,9,Soda
Rana,12,Tea,Milk
Selina,19,Cola

我们将提供一个完整的往返示例,其中使用 apoc.export.arrow.stream.all 来生成 arrow byte[]

CALL apoc.export.arrow.stream.all() YIELD value AS byteArray
CALL apoc.load.arrow.stream(byteArray) YIELD value
RETURN value
结果

{name: "Selma", age: "9", beverage: "Soda"}

{name: "Rana", age: "12", beverage: "Tea;Milk"}

{name: "Selina", age: "19", beverage: "Cola"}