risingwave_stream/executor/
prelude.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15#![allow(unused_imports)]
16
17pub use std::fmt::{Debug, Formatter};
18pub use std::pin::pin;
19pub use std::sync::Arc;
20
21pub use await_tree::InstrumentAwait;
22pub use futures::{Stream, StreamExt, pin_mut};
23pub use futures_async_stream::{for_await, try_stream};
24pub use risingwave_common::array::{RowRef, StreamChunk, StreamChunkBuilder};
25pub use risingwave_common::catalog::Schema;
26pub use risingwave_common::row::{OwnedRow, Row};
27pub use risingwave_common::types::{DataType, Datum, DatumRef, ScalarImpl, ScalarRefImpl};
28pub use risingwave_storage::StateStore;
29
30pub use crate::common::table::state_table::StateTable;
31pub use crate::error::StreamResult;
32pub use crate::executor::actor::{ActorContext, ActorContextRef};
33pub use crate::executor::error::{StreamExecutorError, StreamExecutorResult};
34pub use crate::executor::monitor::streaming_stats::StreamingMetrics;
35pub use crate::executor::{
36    Barrier, BoxedMessageStream, Execute, Executor, ExecutorInfo, Message, MessageStream,
37    MessageStreamItem, Mutation, PkDataTypes, PkIndices, PkIndicesRef, Watermark,
38    expect_first_barrier, expect_first_barrier_from_aligned_stream,
39};
40pub use crate::task::{ActorId, AtomicU64Ref};
risingwave_stream/executor/prelude.rs

risingwave_stream/executor/
prelude.rs
