Function update_check 

pub fn update_check(
    info: Arc<ExecutorInfo>,
    input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>

Streams wrapped by update_check will check whether the two rows of updates are next to each other.