org.apache.spark.sql.execution

Class AddExchange

Object

org.apache.spark.sql.catalyst.rules.Rule<SparkPlan>

org.apache.spark.sql.execution.AddExchange

All Implemented Interfaces:

java.io.Serializable, Logging, scala.Equals, scala.Product

public class AddExchange
extends org.apache.spark.sql.catalyst.rules.Rule<SparkPlan>
implements scala.Product, scala.Serializable

Ensures that the Partitioning of input data meets the Distribution requirements for each operator by inserting Exchange Operators where required.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AddExchange(SQLContext sqlContext)

Method Summary

Methods

Modifier and Type	Method and Description
SparkPlan	apply(SparkPlan plan)
int	numPartitions()
SQLContext	sqlContext()

Methods inherited from class org.apache.spark.sql.catalyst.rules.Rule

isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_, ruleName

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, log_

Constructor Detail

AddExchange

public AddExchange(SQLContext sqlContext)

Method Detail

sqlContext

public SQLContext sqlContext()

numPartitions

public int numPartitions()

apply

public SparkPlan apply(SparkPlan plan)

Specified by:

apply in class org.apache.spark.sql.catalyst.rules.Rule<SparkPlan>