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