2023-01-05 04:46:35 +00:00
|
|
|
= Rust `RecordBatch` Writer Demo
|
|
|
|
|
|
|
|
|
|
This repository contains a simple open source bit of example code for writing
|
|
|
|
|
rows in a link:https://delta.io[Delta table] with
|
|
|
|
|
link:https://github.com/delta-io/delta-rs[the Delta Rust bindings].
|
2023-01-05 04:55:16 +00:00
|
|
|
|
|
|
|
|
You can run this code with:
|
|
|
|
|
|
|
|
|
|
[source,bash]
|
|
|
|
|
----
|
|
|
|
|
TABLE_URI=demo-tables/wx cargo run
|
|
|
|
|
----
|
|
|
|
|
|
|
|
|
|
This will write five data points to the delta table stored in the `wx` directory. You can query this with the `deltalake` Python module, for example:
|
|
|
|
|
|
|
|
|
|
[source, python]
|
|
|
|
|
----
|
|
|
|
|
from deltalake import DeltaTable
|
|
|
|
|
dt = DeltaTable('demo-tables/wx')
|
|
|
|
|
df = dt.to_pandas()
|
|
|
|
|
df.query('temp > 0')
|
|
|
|
|
----
|
