Skip to content

Commit 0121a70

Browse files
author
Jacky Li
committed
add @group tab in limit() and count()
@group tab is missing
1 parent 0fe54cf commit 0121a70

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff 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)

0 commit comments

Comments
 (0)