apoc.export.arrow.stream.query

过程

apoc.export.arrow.stream.query(query ANY, config MAP<STRING, ANY>) - 将给定的 Cypher 查询导出为 Arrow 字节数组。

在多线程环境下运行此过程被认为是不安全的。因此,它不受并行运行时(于 Neo4j 5.13 引入)的支持。更多信息,请参阅 Cypher 手册 → 并行运行时

签名

apoc.export.arrow.stream.query(query :: ANY, config = {} :: MAP) :: (value :: LIST<INTEGER>)

输入参数

名称 类型 默认

query

ANY

null

config

MAP

null

输出参数

名称 类型

LIST<INTEGER>

配置参数

该过程支持以下配置参数

表 1. 配置参数
名称 (name) type 默认 description(描述)

batchSize

整数

2000

ArrowStreamWriter 的批处理大小

使用示例

假设我们有以下数据集

CREATE (f:User {name:'Adam',age:42,male:true,kids:['Sam','Anna','Grace'], born:localdatetime('2015185T19:32:24'), place:point({latitude: 13.1, longitude: 33.46789})})-[:KNOWS {since: 1993, bffSince: duration('P5M1.5D')}]->(b:User {name:'Jim',age:42}),(c:User {name: 'John', age:12}),(d:Another {foo: 'bar'})

使用此查询

CALL apoc.export.arrow.stream.query('MATCH (n:User) RETURN count(n) as count, n.name as name')
YIELD value RETURN value

我们将得到一个包含以下列的表格

  • count

  • 名称 (name)

© . This site is unofficial and not affiliated with Neo4j, Inc.