Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
handle_state in datafusion::physical_plan - Rust
[go: Go Back, main page]

Macro handle_state

Source
macro_rules! handle_state {
    ($match_case:expr) => { ... };
}
Expand description

The handle_state macro is designed to process the result of a state-changing operation. It operates on a StatefulStreamResult by matching its variants and executing corresponding actions. This macro is used to streamline code that deals with state transitions, reducing boilerplate and improving readability.

§Cases

  • Ok(StatefulStreamResult::Continue): Continues the loop, indicating the stream join operation should proceed to the next step.
  • Ok(StatefulStreamResult::Ready(result)): Returns a Poll::Ready with the result, either yielding a value or indicating the stream is awaiting more data.
  • Err(e): Returns a Poll::Ready containing an error, signaling an issue during the stream join operation.

§Arguments

  • $match_case: An expression that evaluates to a Result<StatefulStreamResult<_>>.