CollectLimitExec Physical Operator¶
CollectLimitExec is a unary physical operator that represents GlobalLimit unary logical operator at execution time.
CollectLimitExec takes the following to be created:
Executing Physical Operator¶
In the end,
doExecute (maps over every partition to) takes the given number of rows from the single partition.
doExecute is part of the SparkPlan abstraction.