fix

risingwavelabs · Aug 6, 2024 · 4485c01 · 4485c01
1 parent c14abbb
commit 4485c01
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/frontend/src/optimizer/plan_node/mod.rs b/src/frontend/src/optimizer/plan_node/mod.rs
@@ -900,12 +900,12 @@ mod stream_hash_join;
 mod stream_hop_window;
 mod stream_local_approx_percentile;
 mod stream_materialize;
-mod stream_row_merge;
 mod stream_now;
 mod stream_over_window;
 mod stream_project;
 mod stream_project_set;
 mod stream_row_id_gen;
+mod stream_row_merge;
 mod stream_simple_agg;
 mod stream_sink;
 mod stream_sort;
@@ -1012,12 +1012,12 @@ pub use stream_hash_join::StreamHashJoin;
 pub use stream_hop_window::StreamHopWindow;
 pub use stream_local_approx_percentile::StreamLocalApproxPercentile;
 pub use stream_materialize::StreamMaterialize;
-pub use stream_row_merge::StreamRowMerge;
 pub use stream_now::StreamNow;
 pub use stream_over_window::StreamOverWindow;
 pub use stream_project::StreamProject;
 pub use stream_project_set::StreamProjectSet;
 pub use stream_row_id_gen::StreamRowIdGen;
+pub use stream_row_merge::StreamRowMerge;
 pub use stream_share::StreamShare;
 pub use stream_simple_agg::StreamSimpleAgg;
 pub use stream_sink::{IcebergPartitionInfo, PartitionComputeInfo, StreamSink};

diff --git a/src/stream/src/executor/mod.rs b/src/stream/src/executor/mod.rs
@@ -136,7 +136,6 @@ pub use join::JoinType;
 pub use lookup::*;
 pub use lookup_union::LookupUnionExecutor;
 pub use merge::MergeExecutor;
-pub use row_merge::RowMergeExecutor;
 pub use mview::*;
 pub use no_op::NoOpExecutor;
 pub use now::*;
@@ -146,6 +145,7 @@ pub use project_set::*;
 pub use rearranged_chain::RearrangedChainExecutor;
 pub use receiver::ReceiverExecutor;
 use risingwave_pb::source::{ConnectorSplit, ConnectorSplits};
+pub use row_merge::RowMergeExecutor;
 pub use simple_agg::SimpleAggExecutor;
 pub use sink::SinkExecutor;
 pub use sort::*;

diff --git a/src/stream/src/from_proto/mod.rs b/src/stream/src/from_proto/mod.rs
@@ -81,14 +81,14 @@ use self::hop_window::*;
 use self::lookup::*;
 use self::lookup_union::*;
 use self::merge::*;
-use self::row_merge::*;
 use self::mview::*;
 use self::no_op::*;
 use self::now::NowExecutorBuilder;
 use self::over_window::*;
 use self::project::*;
 use self::project_set::*;
 use self::row_id_gen::RowIdGenExecutorBuilder;
+use self::row_merge::*;
 use self::simple_agg::*;
 use self::sink::*;
 use self::sort::*;