alter state table

Author: Liang Zhao

src/stream/src/executor/now.rs

@@ -22,14 +22,14 @@ use risingwave_common::row::Row;
 use risingwave_common::types::{DataType, NaiveDateTimeWrapper, ScalarImpl};
 use risingwave_common::util::chunk_coalesce::DataChunkBuilder;
 use risingwave_common::util::epoch::Epoch;
-use risingwave_storage::table::streaming_table::state_table::StateTable;
 use risingwave_storage::StateStore;
 use tokio::sync::mpsc::UnboundedReceiver;
 
 use super::{
     Barrier, BoxedMessageStream, Executor, Message, PkIndices, PkIndicesRef, StreamExecutorError,
     Watermark,
 };
+use crate::common::table::state_table::StateTable;
 
 pub struct NowExecutor<S: StateStore> {
     /// Receiver of barrier channel.
@@ -173,10 +173,10 @@ mod tests {
     use risingwave_common::types::{DataType, NaiveDateTimeWrapper, ScalarImpl};
     use risingwave_common::util::sort_util::OrderType;
     use risingwave_storage::memory::MemoryStateStore;
-    use risingwave_storage::table::streaming_table::state_table::StateTable;
     use tokio::sync::mpsc::{unbounded_channel, UnboundedSender};
 
     use super::NowExecutor;
+    use crate::common::table::state_table::StateTable;
     use crate::executor::{Barrier, BoxedMessageStream, Executor, Message, PkIndices, Watermark};
 
     #[tokio::test]

src/stream/src/from_proto/now.rs

@@ -15,11 +15,11 @@
 use risingwave_common::try_match_expand;
 use risingwave_pb::stream_plan::stream_node::NodeBody;
 use risingwave_pb::stream_plan::StreamNode;
-use risingwave_storage::table::streaming_table::state_table::StateTable;
 use risingwave_storage::StateStore;
 use tokio::sync::mpsc::unbounded_channel;
 
 use super::ExecutorBuilder;
+use crate::common::table::state_table::StateTable;
 use crate::error::StreamResult;
 use crate::executor::{BoxedExecutor, NowExecutor};
 use crate::task::{ExecutorParams, LocalStreamManagerCore};