arrow
import
Import an Arrow-compatible file into a product primitive.
strata arrow importdb.arrow.import_(target: 'str', path: 'str', *, format: 'Optional[str]' = None, collection: 'Optional[str]' = None, graph: 'Optional[str]' = None, key_column: 'Optional[str]' = None, value_column: 'Optional[str]' = None) -> 'Any'wire arrow_import
Imports an Arrow-compatible file (Parquet, CSV, or JSONL) into a product primitive on the selected branch and space. Rows are written through the standard batch commands, so the import commits like any other write. Returns a summary of the target primitive, the input file, and the imported, skipped, and batch counts.
Status commands return a scalar or compact status payload and do not mutate database state.
To see the complete help for this command, run:
strata arrow import --helphelp(db.arrow.import_)
Example
Import a primitive's rows from a Parquet file written by export.
strata kv put greeting hellostrata command run --command-json '{"format":"parquet","path":"/tmp/exports/kv.parquet","primitive":"kv","type":"arrow_export"}'strata kv delete greetingstrata arrow import /tmp/exports/kv.parquet --target kv # Rows are keyed by their source column; kv restores greeting=hello.strata kv get greeting
_ = db.kv.put("greeting", "hello")_ = db.arrow.export("kv", tmp_dir + "/kv.parquet", format="parquet")_ = db.kv.delete("greeting")_ = db.arrow.import_("kv", tmp_dir + "/kv.parquet") # Rows are keyed by their source column; kv restores greeting=hello.db.kv.get("greeting")
Parameters
| Name | Type | Required | Description |
|---|---|---|---|
| file_path | string | yes | Input file path. |
| target | ArrowImportTarget | yes | Product primitive to import into.one of: kv, json, vector, graph, event |
| branch | string or null | no | Target branch. Defaults to the executor handle branch. |
| collection | string or null | no | Target vector collection for vector imports. |
| format | any | no | Input file format. Defaults to extension detection. |
| graph | string or null | no | Target graph for graph imports. |
| key_column | string or null | no | Optional key column override. |
| space | string or null | no | Target product space. Defaults to `"default"`. |
| value_column | string or null | no | Optional value, document, or embedding column override. |
Returns
StatusResponse<ArrowImport>
- dataArrowImportResult
- typestring
Errors
Recover by code. Retry policy and commit outcome come from the shipped error registry.