Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
24e1048
docs: Add spec for Parquet dump/restore
lutter Feb 21, 2026
8d9a40c
docs: Document the deployment dump format
lutter Feb 24, 2026
9446e48
store: Add OidValue::Int4Range and fix block_range binding
lutter Feb 21, 2026
84a290b
store: Make infrastructure columns visible in Table::column()
lutter Feb 21, 2026
7196d3d
store: Add parquet module with Arrow schema mapping
lutter Feb 21, 2026
5b6f2da
store: Add OidValue to Arrow RecordBatch conversion
lutter Feb 21, 2026
6337adb
store: Add Parquet chunk file writer
lutter Feb 21, 2026
80390aa
store: Implement Parquet dump for subgraph data
lutter Feb 21, 2026
6874701
node: Add graphman dump command
lutter Feb 21, 2026
f03663b
store: Add Parquet reader for restore
lutter Feb 22, 2026
14c6cb7
store: Add Arrow-to-Value conversion for restore
lutter Feb 22, 2026
9198f5d
store: Add InsertQuery::for_restore() for Parquet restore
lutter Feb 22, 2026
112472d
store: Add Metadata::from_file() for dump deserialization
lutter Feb 22, 2026
d1bc50d
store: Add core restore module for schema & deployment creation
lutter Feb 22, 2026
48a6b7d
store: Add resumable entity data import for restore
lutter Feb 22, 2026
3cc2f13
store: Add restore finalization with vid sequence reset and head bloc…
lutter Feb 22, 2026
1bbf19c
store: Add shard-aware restore planning with RestoreMode and RestoreA…
lutter Feb 22, 2026
ffc6bf1
store: Add restore orchestration in SubgraphStore and DeploymentStore
lutter Feb 23, 2026
ae089ca
node: Add graphman restore command
lutter Feb 23, 2026
4e050c2
store: Use REPEATABLE READ transaction for consistent dump
lutter Feb 23, 2026
a1cd9bf
store: Stream parquet batches lazily during restore
lutter Mar 3, 2026
acf3f63
graph, node, store: Change how restore deterimes the shard
lutter Mar 3, 2026
4bc7137
store: Validate subgraph name exists before restore
lutter Mar 3, 2026
86f56d6
node: Create dump output directory if it doesn't exist
lutter Mar 3, 2026
efa8479
store: Use the table alias properly when dumping a table
lutter Mar 3, 2026
56197d9
store: Batch data_sources$ inserts during restore
lutter Mar 3, 2026
f220a94
graph, node, store: Add progress reporting for dump and restore
lutter Mar 3, 2026
d41fe95
graph, node, store: Add incremental dump support
lutter Mar 7, 2026
0813ba6
store: Skip null values in fulltext field reconstruction
lutter Mar 7, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
120 changes: 112 additions & 8 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 3 additions & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ chrono = "0.4.44"
bs58 = "0.5.1"
clap = { version = "4.5.4", features = ["derive", "env", "wrap_help"] }
clap_complete = "4"
console = "0.16"
derive_more = { version = "2.1.1", default-features = false }
diesel = { version = "2.2.7", features = [
"postgres",
Expand All @@ -70,6 +71,7 @@ graphman-server = { path = "./server/graphman" }
graphman = { path = "./core/graphman" }
graphman-store = { path = "./core/graphman_store" }
graphql-tools = "0.5.1"
indicatif = "0.18"
Inflector = "0.11.3"
itertools = "0.14.0"
lazy_static = "1.5.0"
Expand Down Expand Up @@ -116,6 +118,7 @@ url = "2.5.8"
ahash = "0.8.11"
arrow = { version = "=58.0.0" }
arrow-flight = { version = "=58.0.0", features = ["flight-sql-experimental"] }
parquet = { version = "=58.0.0" }
futures = "0.3.31"
half = "2.7.1"
indoc = "2.0.7"
Expand Down
1 change: 1 addition & 0 deletions docs/implementation/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,3 +10,4 @@ the code should go into comments.
* [SQL Query Generation](./sql-query-generation.md)
* [Adding support for a new chain](./add-chain.md)
* [Pruning](./pruning.md)
* [Dump Format](./dump.md)
Loading