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 { ... }
}