pub fn update_check(
info: Arc<ExecutorInfo>,
input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>Expand description
Streams wrapped by update_check will check whether the two rows of updates are next to each
other.