Module prelude

Re-exports

• pub use crate::common::table::state_table::StateTable;
• pub use crate::executor::test_utils::expr::build_from_pretty;
• pub use crate::executor::test_utils::MessageSender;
• pub use crate::executor::test_utils::MockSource;
• pub use crate::executor::test_utils::StreamExecutorTestExt;
• pub use crate::executor::ActorContext;
• pub use crate::executor::BoxedMessageStream;
• pub use crate::executor::Execute;
• pub use crate::executor::PkIndices;

Structs

• Arc
  A thread-safe reference-counting pointer. ‘Arc’ stands for ‘Atomically Reference Counted’.
• AtomicU64
  An integer type which can be safely shared between threads.
• ColumnDesc
• ColumnId
  Column ID is the unique identifier of a column in a table. Different from table ID, column ID is not globally unique.
• Field
  The field in the schema of the executor’s return data
• OrderType
  Order type of a column.
• Schema
  the schema of the executor’s return data
• StreamChunk
  StreamChunk is used to pass data over the streaming pathway.
• TableId

Enums

• DataType
  The set of datatypes that are supported in RisingWave.

Traits

• StateStore
• StreamChunkTestExt
  Test utilities for StreamChunk.

Type Aliases

• MemoryStateStore