Skip to content

Commit fc5f88e

Browse files
Pin toolchain version in CI
1 parent 0b390f3 commit fc5f88e

File tree

3 files changed

+19
-6
lines changed

3 files changed

+19
-6
lines changed

.github/workflows/ci.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ jobs:
2424
- name: Install minimal nightly with clippy and rustfmt
2525
uses: dtolnay/rust-toolchain@master
2626
with:
27-
toolchain: nightly
27+
toolchain: nightly-2025-01-23
2828
components: rustfmt, clippy
2929

3030
- name: Install tool for formatting Cargo.toml files

README.md

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,17 +11,30 @@ Load data from Parquet and Postgres to Delta Lake
1111

1212
Download the binary from the [Releases page](./releases)
1313

14-
To load data from Postgres to Delta Lake:
14+
Load data from Postgres to Delta Lake:
1515

1616
```bash
1717
export PGPASSWORD="my_password"
18-
./lakehouse-loader pg-to-delta postgres://test-user@localhost:5432/test-db -q "SELECT * FROM some_table" s3://my-bucket/path/to/table
18+
./lakehouse-loader pg-to-delta postgres://test-user@localhost:5432/test-db -q "SELECT * FROM some_table" s3://my-bucket/path/to/delta/table
1919
```
2020

21-
To load data from Parquet to Delta Lake:
21+
Load data from Parquet to Delta Lake:
2222

2323
```bash
24-
./lakehouse-loader parquet-to-delta some_file.parquet s3://my-bucket/path/to/table
24+
./lakehouse-loader parquet-to-delta some_file.parquet s3://my-bucket/path/to/delta/table
25+
```
26+
27+
Load data from Postgres to Iceberg File Catalog:
28+
29+
```bash
30+
export PGPASSWORD="my_password"
31+
./lakehouse-loader pg-to-iceberg postgres://test-user@localhost:5432/test-db -q "SELECT * FROM some_table" s3://my-bucket/path/to/iceberg/table
32+
```
33+
34+
Load data from Parquet to Iceberg File Catalog:
35+
36+
```bash
37+
./lakehouse-loader parquet-to-iceberg some_file.parquet s3://my-bucket/path/to/iceberg/table
2538
```
2639

2740
Supports standard AWS environment variables (e.g. AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_PROFILE, AWS_ENDPOINT etc).

src/delta_destination.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -441,7 +441,7 @@ pub async fn record_batches_to_delta(
441441
.await?;
442442

443443
let delta_schema = deltalake::kernel::Schema::try_from(schema)?;
444-
let table_name = target_url.path_segments().unwrap().last().unwrap();
444+
let table_name = target_url.path_segments().unwrap().next_back().unwrap();
445445

446446
let table = CreateBuilder::new()
447447
.with_log_store(log_store.clone())

0 commit comments

Comments
 (0)