File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
sql/core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -225,6 +225,8 @@ class SchemaRDD(
225225 * {{{
226226 * schemaRDD.limit(10)
227227 * }}}
228+ *
229+ * @group Query
228230 */
229231 def limit (limitNum : Int ): SchemaRDD =
230232 new SchemaRDD (sqlContext, Limit (Literal (limitNum), logicalPlan))
@@ -355,6 +357,8 @@ class SchemaRDD(
355357 * Return the number of elements in the RDD. Unlike the base RDD implementation of count, this
356358 * implementation leverages the query optimizer to compute the count on the SchemaRDD, which
357359 * supports features such as filter pushdown.
360+ *
361+ * @group Query
358362 */
359363 @ Experimental
360364 override def count (): Long = aggregate(Count (Literal (1 ))).collect().head.getLong(0 )
You can’t perform that action at this time.
0 commit comments