apoc.load.arrow.stream

Details

Syntax

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

Description

Imports NODE and RELATIONSHIP values from the provided arrow byte array.

Input arguments

Name

Type

Description

source

BYTEARRAY

The data to load.

config

MAP

This value is never used. The default is: {}.

Return arguments

Name

Type

Description

value

MAP

A map of data loaded from the given file.

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
Results
value

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

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

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