Module prelude

Re-exports

pub use crate::common::table::state_table::StateTable;

pub use crate::error::StreamResult;

pub use crate::executor::actor::ActorContext;

pub use crate::executor::actor::ActorContextRef;

pub use crate::executor::error::StreamExecutorError;

pub use crate::executor::error::StreamExecutorResult;

pub use crate::executor::monitor::streaming_stats::StreamingMetrics;

pub use crate::executor::Barrier;

pub use crate::executor::BoxedMessageStream;

pub use crate::executor::Execute;

pub use crate::executor::Executor;

pub use crate::executor::ExecutorInfo;

pub use crate::executor::Message;

pub use crate::executor::MessageStream;

pub use crate::executor::MessageStreamItem;

pub use crate::executor::Mutation;

pub use crate::executor::PkDataTypes;

pub use crate::executor::PkIndices;

pub use crate::executor::PkIndicesRef;

pub use crate::executor::Watermark;

pub use crate::executor::expect_first_barrier;

pub use crate::executor::expect_first_barrier_from_aligned_stream;

pub use crate::task::ActorId;

pub use crate::task::AtomicU64Ref;

Macros

pin

Constructs a Pin<&mut T>, by pinning a value: T locally.

pin_mut

Pins a value on the stack.

Structs

Arc

A thread-safe reference-counting pointer. ‘Arc’ stands for ‘Atomically Reference Counted’.

Formatter

Configuration for formatting.

OwnedRow

An owned row type with a Vec<Datum>.

RowRef

Schema

the schema of the executor’s return data

StreamChunk

StreamChunk is used to pass data over the streaming pathway.

StreamChunkBuilder

Build stream chunks with fixed chunk size from rows or records.

Enums

DataType

The set of datatypes that are supported in RisingWave.

ScalarImpl

ScalarImpl embeds all possible scalars in the evaluation framework.

ScalarRefImpl

ScalarRefImpl embeds all possible scalar references in the evaluation framework.

Traits

Debug

? formatting.

InstrumentAwait

Attach spans to a future to be traced in the await-tree.

Row

The trait for abstracting over a Row-like type.

StateStore

Stream

A stream of values produced asynchronously.

StreamExt

An extension trait for Streams that provides a variety of convenient combinator functions.

Type Aliases

Datum

DatumRef

Attribute Macros

for_await

Processes streams using a for loop.

try_stream

Creates streams via coroutines.

Derive Macros

Debug

Derive macro generating an impl of the trait Debug.