refactor: move row_id to common (#8513)

risingwavelabs · Mar 14, 2023 · d06674b · d06674b
1 parent 9bf2e8c
commit d06674b
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 2 deletions.
diff --git a/src/common/src/util/mod.rs b/src/common/src/util/mod.rs
@@ -32,6 +32,7 @@ pub mod iter_util;
 pub mod ordered;
 pub mod prost;
 pub mod resource_util;
+pub mod row_id;
 pub mod scan_range;
 pub mod schema_check;
 pub mod sort_util;

diff --git a/src/source/src/row_id.rs → src/common/src/util/row_id.rs b/src/source/src/row_id.rs → src/common/src/util/row_id.rs
diff --git a/src/source/src/lib.rs b/src/source/src/lib.rs
@@ -32,5 +32,4 @@ pub mod connector_source;
 pub mod source_desc;
 pub use source_desc::test_utils as connector_test_utils;
 pub mod fs_connector_source;
-pub mod row_id;
 mod table;
diff --git a/src/stream/src/executor/row_id_gen.rs b/src/stream/src/executor/row_id_gen.rs
@@ -21,7 +21,7 @@ use risingwave_common::buffer::Bitmap;
 use risingwave_common::catalog::Schema;
 use risingwave_common::util::epoch::UNIX_RISINGWAVE_DATE_EPOCH;
 use risingwave_common::util::iter_util::ZipEqFast;
-use risingwave_source::row_id::RowIdGenerator;
+use risingwave_common::util::row_id::RowIdGenerator;
 
 use super::{
     expect_first_barrier, ActorContextRef, BoxedExecutor, Executor, PkIndices, PkIndicesRef,