File tree Expand file tree Collapse file tree 1 file changed +23
-9
lines changed
docs/data_engineering/data_lakehouse/delta_lake Expand file tree Collapse file tree 1 file changed +23
-9
lines changed Original file line number Diff line number Diff line change 1- # Rust package: delta-rs
1+ title: delta-rs
2+
3+ # delta-rs (Rust)
4+
5+ # Dependencies
6+
7+ ``` toml
8+ [dependencies ]
9+ deltalake = { version = " 0.22.3" , features = [" datafusion" , " s3" ] }
10+ tokio = " 1.42.0"
11+ ```
12+
13+ The ` datafusion ` feature is needed to write data to a table.
214
315## S3 configurations
416
@@ -25,19 +37,21 @@ S3 requires a locking provider by default ([more information](https://delta-io.g
2537## Create table
2638
2739``` rust
28- use deltalake :: {kernel :: DataType , DeltaOps };
40+ use deltalake :: {
41+ kernel :: {DataType , StructField },
42+ DeltaOps ,
43+ };
2944
3045#[tokio:: main()]
3146async fn main () {
3247 let delta_ops = DeltaOps :: new_in_memory ();
3348
34- let table = delta_ops
35- . create ()
36- . with_table_name (" employee" )
37- . with_column (" id" , DataType :: INTEGER , false , Default :: default ())
38- . with_column (" name" , DataType :: STRING , false , Default :: default ())
39- . await
40- . expect (" Table creation failed" );
49+ let columns = vec! [
50+ StructField :: new (" id" , DataType :: INTEGER , false ),
51+ StructField :: new (" name" , DataType :: INTEGER , false ),
52+ StructField :: new (" age" , DataType :: INTEGER , false ),
53+ ];
54+ let table = delta_ops . create (). with_table_name (" employee" ). with_columns (columns ). await . expect (" Table creation failed" );
4155}
4256```
4357
You can’t perform that action at this time.
0 commit comments