Skip to content

Commit d5e7ddd

Browse files
luoluoyuyuluoluoyuyu
committed
update
1 parent b8933e8 commit d5e7ddd

174 files changed

Lines changed: 468 additions & 349 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎Cargo.lock‎

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

‎Cargo.toml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ members = [
1010
"src/coordinator",
1111
"src/job_manager",
1212
"src/logger",
13+
"src/runtime_common",
1314
"src/servicer",
1415
"src/sqlparser",
1516
"src/streaming_runtime",
@@ -48,6 +49,7 @@ num_cpus = "1.0"
4849
protocol = { path = "./protocol" }
4950
function-stream-config = { path = "src/config" }
5051
function-stream-logger = { path = "src/logger" }
52+
function-stream-runtime-common = { path = "src/runtime_common" }
5153
prost = "0.13"
5254
rdkafka = { version = "0.38", features = ["cmake-build", "ssl", "gssapi", "curl"] }
5355
crossbeam-channel = "0.5"

‎src/catalog_storage/src/lib.rs‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,7 @@
11
//! Persistent catalog storage implementations.
2+
//!
3+
//! The stream catalog manager and task persistence (`stream_catalog/`, `task/`) live in this
4+
//! package and are compiled as part of `function-stream` via `#[path]` in `src/storage/mod.rs`.
25
36
pub mod memory;
47
pub mod rocksdb;

src/storage/stream_catalog/codec.rs renamed to src/catalog_storage/src/stream_catalog/codec.rs

File renamed without changes.

src/storage/stream_catalog/manager.rs renamed to src/catalog_storage/src/stream_catalog/manager.rs

File renamed without changes.

src/storage/stream_catalog/meta_store.rs renamed to src/catalog_storage/src/stream_catalog/meta_store.rs

File renamed without changes.

src/storage/stream_catalog/mod.rs renamed to src/catalog_storage/src/stream_catalog/mod.rs

File renamed without changes.

src/storage/stream_catalog/rocksdb_meta_store.rs renamed to src/catalog_storage/src/stream_catalog/rocksdb_meta_store.rs

File renamed without changes.

src/storage/task/factory.rs renamed to src/catalog_storage/src/task/factory.rs

File renamed without changes.

src/storage/task/function_info.rs renamed to src/catalog_storage/src/task/function_info.rs

File renamed without changes.

0 commit comments

Comments
 (0)