StreamingGlobalLimitExec

StreamingGlobalLimitExec is…​FIXME

StreamingGlobalLimitExec uses the performance metrics of StateStoreWriter.

Executing Physical Operator — doExecute Method

doExecute(): RDD[InternalRow]
Note
doExecute is a part of SparkPlan contract to produce the result of a physical operator as an RDD of internal binary rows (i.e. InternalRow).

doExecute…​FIXME

results matching ""

    No results matching ""