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).