From d06674b2c1c4a859abbc9bb70fddb5acdc430a14 Mon Sep 17 00:00:00 2001
From: Shanicky Chen <peng@singularity-data.com>
Date: Tue, 14 Mar 2023 14:53:40 +0800
Subject: [PATCH] refactor: move row_id to common (#8513)

---
 src/common/src/util/mod.rs                    | 1 +
 src/{source/src => common/src/util}/row_id.rs | 0
 src/source/src/lib.rs                         | 1 -
 src/stream/src/executor/row_id_gen.rs         | 2 +-
 4 files changed, 2 insertions(+), 2 deletions(-)
 rename src/{source/src => common/src/util}/row_id.rs (100%)

diff --git a/src/common/src/util/mod.rs b/src/common/src/util/mod.rs
index 022c8443048be..0420b0c59690a 100644
--- 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 b/src/common/src/util/row_id.rs
similarity index 100%
rename from src/source/src/row_id.rs
rename to src/common/src/util/row_id.rs
diff --git a/src/source/src/lib.rs b/src/source/src/lib.rs
index d9b0725e55388..ce31cf283be76 100644
--- 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
index 8489893d435d6..eea4a3bba7c23 100644
--- 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,