org.apache.spark.sql.execution

Class TakeOrdered

Object

org.apache.spark.sql.catalyst.trees.TreeNode<PlanType>

org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>

org.apache.spark.sql.execution.SparkPlan

org.apache.spark.sql.execution.TakeOrdered

All Implemented Interfaces:

com.typesafe.scalalogging.slf4j.Logging, java.io.Serializable, scala.Equals, scala.Product

public class TakeOrdered
extends SparkPlan
implements scala.Product, scala.Serializable

:: DeveloperApi :: Take the first limit elements as defined by the sortOrder. This is logically equivalent to having a Limit operator after a Sort operator. This could have been named TopK, but Spark's top operator does the opposite in ordering so we name it TakeOrdered to avoid confusion.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TakeOrdered(int limit, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> sortOrder, SparkPlan child, SQLContext sqlContext)

Method Summary

Methods

Modifier and Type	Method and Description
SparkPlan	child()
RDD<org.apache.spark.sql.catalyst.expressions.Row>	execute() Runs this query returning the result as an RDD.
org.apache.spark.sql.catalyst.expressions.Row[]	executeCollect() Runs this query returning the result as an array.
int	limit()
org.apache.spark.sql.catalyst.expressions.RowOrdering	ordering()
scala.collection.immutable.List<SQLContext>	otherCopyArgs()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
org.apache.spark.sql.catalyst.plans.physical.Partitioning	outputPartitioning()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder>	sortOrder()

Methods inherited from class org.apache.spark.sql.execution.SparkPlan

outputPartitioning, requiredChildDistribution

Methods inherited from class org.apache.spark.sql.catalyst.plans.QueryPlan

expressions, generateSchemaString, generateSchemaString, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, outputSet, printSchema, schemaString, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

Methods inherited from class org.apache.spark.sql.catalyst.trees.TreeNode

apply, argString, asCode, children, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, id, makeCopy, map, mapChildren, nextId, nodeName, numberedTreeString, sameInstance, simpleString, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildren

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.catalyst.trees.UnaryNode

children

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface com.typesafe.scalalogging.slf4j.Logging

logger

Constructor Detail

TakeOrdered

public TakeOrdered(int limit,
           scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> sortOrder,
           SparkPlan child,
           SQLContext sqlContext)

Method Detail

limit

public int limit()

sortOrder

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> sortOrder()

child

public SparkPlan child()

otherCopyArgs

public scala.collection.immutable.List<SQLContext> otherCopyArgs()

output

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()

Specified by:

output in class org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>

ordering

public org.apache.spark.sql.catalyst.expressions.RowOrdering ordering()

executeCollect

public org.apache.spark.sql.catalyst.expressions.Row[] executeCollect()

Description copied from class: SparkPlan

Runs this query returning the result as an array.

Overrides:

executeCollect in class SparkPlan

execute

public RDD<org.apache.spark.sql.catalyst.expressions.Row> execute()

Description copied from class: SparkPlan

Runs this query returning the result as an RDD.

Specified by:

execute in class SparkPlan

outputPartitioning

public org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()