StreamingGlobalLimitStrategy Execution Planning Strategy

StreamingGlobalLimitStrategy is an execution planning strategy that can plan streaming queries with ReturnAnswer and Limit logical operators (over streaming queries) with the Append output mode to StreamingGlobalLimitExec physical operator.

Tip
 Read up on Execution Planning Strategies in The Internals of Spark SQL book.

StreamingGlobalLimitStrategy is used (and created) exclusively when IncrementalExecution is requested to plan a streaming query.

StreamingGlobalLimitStrategy takes a single OutputMode to be created (which is the OutputMode of the IncrementalExecution).

Demo: Using StreamingGlobalLimitStrategy

FIXME

results matching ""

    No results matching ""