public class Exchange extends SparkPlan implements scala.Product, scala.Serializable
| Constructor and Description |
|---|
Exchange(org.apache.spark.sql.catalyst.plans.physical.Partitioning newPartitioning,
SparkPlan child) |
| 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.plans.physical.Partitioning |
newPartitioning() |
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> |
output() |
org.apache.spark.sql.catalyst.plans.physical.Partitioning |
outputPartitioning()
Specifies how data is partitioned across different nodes in the cluster.
|
codegenEnabled, executeCollect, makeCopy, requiredChildDistributionexpressions, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, outputSet, printSchema, schema, schemaString, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUpapply, argString, asCode, children, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, id, map, mapChildren, nextId, nodeName, numberedTreeString, otherCopyArgs, sameInstance, simpleString, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildrenproductArity, productElement, productIterator, productPrefixinitialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarningpublic Exchange(org.apache.spark.sql.catalyst.plans.physical.Partitioning newPartitioning,
SparkPlan child)
public org.apache.spark.sql.catalyst.plans.physical.Partitioning newPartitioning()
public SparkPlan child()
public org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()
SparkPlanoutputPartitioning in class SparkPlanpublic scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()
output in class org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>