spark-sql-streaming-StreamingGlobalLimitExec.adoc

StreamingGlobalLimitExec

StreamingGlobalLimitExec is…​FIXME

StreamingGlobalLimitExec uses the performance metrics of StateStoreWriter.

Executing Physical Operator (Generating RDD[InternalRow]) — doExecute Method

doExecute(): RDD[InternalRow]

Note	doExecute is part of SparkPlan Contract to generate the runtime representation of an physical operator as a distributed computation over internal binary rows on Apache Spark (i.e. RDD[InternalRow]).

doExecute…​FIXME