risingwave_stream::executor::test_utils::hash_join_executor

Function build_chunk

Source 
fn build_chunk(size: usize, join_key_value: i64) -> StreamChunk