Skip to content

Commit 36ce529

Browse files
authored
fix(clickhouse): refactor to read rows with async streaming (#515)
1 parent 1267083 commit 36ce529

File tree

4 files changed

+716
-538
lines changed

4 files changed

+716
-538
lines changed

Cargo.lock

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

wrappers/Cargo.toml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,9 @@ clickhouse_fdw = [
4545
"thiserror",
4646
"either",
4747
"uuid",
48+
"crossbeam",
49+
"tokio",
50+
"futures-util",
4851
]
4952
stripe_fdw = [
5053
"http",
@@ -231,6 +234,8 @@ clickhouse-rs = { git = "https://github.com/burmecia/clickhouse-rs.git", branch
231234
chrono = { version = "0.4", optional = true }
232235
chrono-tz = { version = "0.6", optional = true }
233236
either = { version = "1.12.0", optional = true }
237+
crossbeam = { version = "0.8.4", optional = true }
238+
futures-util = { version = "0.3.31", optional = true }
234239

235240
# for bigquery_fdw, firebase_fdw, airtable_fdw and etc.
236241
gcp-bigquery-client = { version = "0.25.1", optional = true }

wrappers/src/fdw/clickhouse_fdw/README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ This is a foreign data wrapper for [ClickHouse](https://clickhouse.com/). It is
1111

1212
| Version | Date | Notes |
1313
| ------- | ---------- | ---------------------------------------------------- |
14+
| 0.1.8 | 2025-10-27 | Refactor to read rows with async streaming |
1415
| 0.1.7 | 2025-05-22 | Added more data types support |
1516
| 0.1.6 | 2025-05-06 | Added UUID data type support |
1617
| 0.1.5 | 2024-09-30 | Support for pgrx 0.12.6 |

0 commit comments

Comments
 (0)