Function normalize_update_chunk_by_key 

fn normalize_update_chunk_by_key(
    chunk: StreamChunk,
    key_indices: &[usize],
) -> Option<StreamChunk>