Skip to content

Commit d06674b

Browse files
authored
refactor: move row_id to common (risingwavelabs#8513)
1 parent 9bf2e8c commit d06674b

File tree

4 files changed

+2
-2
lines changed

4 files changed

+2
-2
lines changed

src/common/src/util/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ pub mod iter_util;
3232
pub mod ordered;
3333
pub mod prost;
3434
pub mod resource_util;
35+
pub mod row_id;
3536
pub mod scan_range;
3637
pub mod schema_check;
3738
pub mod sort_util;
File renamed without changes.

src/source/src/lib.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,4 @@ pub mod connector_source;
3232
pub mod source_desc;
3333
pub use source_desc::test_utils as connector_test_utils;
3434
pub mod fs_connector_source;
35-
pub mod row_id;
3635
mod table;

src/stream/src/executor/row_id_gen.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use risingwave_common::buffer::Bitmap;
2121
use risingwave_common::catalog::Schema;
2222
use risingwave_common::util::epoch::UNIX_RISINGWAVE_DATE_EPOCH;
2323
use risingwave_common::util::iter_util::ZipEqFast;
24-
use risingwave_source::row_id::RowIdGenerator;
24+
use risingwave_common::util::row_id::RowIdGenerator;
2525

2626
use super::{
2727
expect_first_barrier, ActorContextRef, BoxedExecutor, Executor, PkIndices, PkIndicesRef,

0 commit comments

Comments
 (0)