Skip to content

Commit a5ebfeb

Browse files
committed
Optimize ScyllaDB's batch writes
1 parent 3524ba5 commit a5ebfeb

File tree

6 files changed

+294
-67
lines changed

6 files changed

+294
-67
lines changed

Cargo.lock

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

examples/Cargo.lock

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

linera-indexer/lib/src/scylla_db.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,9 @@
33

44
use linera_views::{
55
lru_caching::StorageCacheConfig,
6-
scylla_db::{ScyllaDbStore, ScyllaDbStoreConfig, ScyllaDbStoreInternalConfig},
6+
scylla_db::{
7+
ScyllaDbClientConfig, ScyllaDbStore, ScyllaDbStoreConfig, ScyllaDbStoreInternalConfig,
8+
},
79
store::AdminKeyValueStore,
810
};
911

@@ -62,6 +64,7 @@ impl ScyllaDbRunner {
6264
max_stream_queries: config.client.max_stream_queries,
6365
max_concurrent_queries: config.client.max_concurrent_queries,
6466
replication_factor: config.client.replication_factor,
67+
client_config: ScyllaDbClientConfig::default(),
6568
};
6669
let store_config = ScyllaDbStoreConfig {
6770
inner_config,

linera-service/src/storage.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ use {
3434
};
3535
#[cfg(feature = "scylladb")]
3636
use {
37-
linera_views::scylla_db::{ScyllaDbStore, ScyllaDbStoreConfig, ScyllaDbStoreInternalConfig},
37+
linera_views::scylla_db::{
38+
ScyllaDbClientConfig, ScyllaDbStore, ScyllaDbStoreConfig, ScyllaDbStoreInternalConfig,
39+
},
3840
std::num::NonZeroU16,
3941
tracing::debug,
4042
};
@@ -486,6 +488,7 @@ impl StorageConfig {
486488
max_stream_queries: options.storage_max_stream_queries,
487489
max_concurrent_queries: options.storage_max_concurrent_queries,
488490
replication_factor: options.storage_replication_factor,
491+
client_config: ScyllaDbClientConfig::default(),
489492
};
490493
let config = ScyllaDbStoreConfig {
491494
inner_config,
@@ -514,6 +517,7 @@ impl StorageConfig {
514517
max_stream_queries: options.storage_max_stream_queries,
515518
max_concurrent_queries: options.storage_max_concurrent_queries,
516519
replication_factor: options.storage_replication_factor,
520+
client_config: ScyllaDbClientConfig::default(),
517521
};
518522
let second_config = ScyllaDbStoreConfig {
519523
inner_config,

linera-views/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ linera-base.workspace = true
4646
linera-views-derive.workspace = true
4747
linera-witty.workspace = true
4848
linked-hash-map.workspace = true
49+
lru.workspace = true
4950
prometheus.workspace = true
5051
rand = { workspace = true, features = ["small_rng"] }
5152
rocksdb = { workspace = true, optional = true }

0 commit comments

Comments
 (0)