apoc.load.arrow.stream

Procedure

apoc.load.arrow.stream(source LIST<INTEGER>, config MAP<STRING, ANY>) - imports NODE and RELATIONSHIP values from the provided arrow byte array.

Signature

apoc.load.arrow.stream(source :: LIST<INTEGER>, config = {} :: MAP) :: (value :: MAP)

Input parameters

Name Type Default

source

LIST<INTEGER>

null

config

MAP

null

Output parameters

Name Type

value

MAP

Usage Examples

Given an Arrow byte[] contains people and their properties:

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

We’ll provide a full roundtrip example where we use the apoc.export.arrow.stream.all in order to generate the arrow byte[]

CALL apoc.export.arrow.stream.all() YIELD value AS byteArray
CALL apoc.load.arrow.stream(byteArray) YIELD value
RETURN value
Table 1. Results
value

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

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

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