Skip to main content

Module export

Module export 

Source
Expand description

Graph → lakehouse: export FalkorDB query results back to GraphAr files.

The reverse of the ingest bridge. FalkorDbLoader writes Arrow into FalkorDB; this reads a Cypher query’s result rows back out as Arrow and writes them as a chunked GraphAr file (parquet/csv/orc/json/ arrow-ipc) — so a graph computed in FalkorDB can land back in the lakehouse (and from there into Iceberg, object storage, etc.). Both directions of the columnar ↔ graph bridge now exist.

Structs§

ExportReport
Outcome of an export_cypher / export_cypher_chunked call.

Functions§

export_cypher
Run cypher against the executor’s graph and write the result rows as one GraphAr chunk file at path in file_type. Returns what was written.
export_cypher_chunked
Run cypher and write the result as multiple GraphAr chunk files — chunk0.<ext>, chunk1.<ext>, … — under dir, each holding at most chunk_rows rows. This is the chunked export for huge results: instead of one monolithic file it lands the result the way GraphAr naturally tiles a vertex/edge collection (one file per row-range), so a VertexReader (or a plain read_chunk per file) can stream the chunks back without ever holding the whole result in memory.
write_batch_chunked
Slice one in-memory RecordBatch into chunk_rows-sized record batches and write each as chunk{i}.<ext> under dir. Split out from export_cypher_chunked so the chunking can be exercised (round-tripped) without a FalkorDB connection.