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::expect_first_barrier;
• pub use crate::executor::expect_first_barrier_from_aligned_stream;
• 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::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.