risingwave_common::test_utils::test_stream_chunk

Trait TestStreamChunk

pub trait TestStreamChunk {
    // Required methods
    fn stream_chunk(&self) -> StreamChunk;
    fn cardinality(&self) -> usize;
    fn schema(&self) -> Schema;
    fn op_at(&self, idx: usize) -> Op;
    fn row_at(&self, idx: usize) -> OwnedRow;

    // Provided methods
    fn pk_indices(&self) -> Vec<usize> { ... }
    fn data_types(&self) -> Vec<DataType> { ... }
    fn row_with_op_at(&self, idx: usize) -> (Op, OwnedRow) { ... }
    fn value_at(&self, row_idx: usize, col_idx: usize) -> Datum { ... }
}