org.apache.spark.sql.hive.execution

Class CreateTableAsSelect

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.hive.execution.CreateTableAsSelect

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.trees.LeafNode<SparkPlan>, Command, scala.Equals, scala.Product

public class CreateTableAsSelect
extends SparkPlan
implements LeafNode, Command, scala.Product, scala.Serializable

:: Experimental :: Create table and insert the query result into it.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CreateTableAsSelect(String database, String tableName, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query, boolean allowExisting, scala.Option<org.apache.hadoop.hive.ql.plan.CreateTableDesc> desc)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowExisting()
String	argString()
String	database()
scala.Option<org.apache.hadoop.hive.ql.plan.CreateTableDesc>	desc()
RDD<org.apache.spark.sql.catalyst.expressions.Row>	execute() Runs this query returning the result as an RDD.
scala.collection.Seq<scala.runtime.Nothing$>	output()
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	query()
String	tableName()

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

codegenEnabled, executeCollect, makeCopy, outputPartitioning, requiredChildDistribution

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

expressions, inputSet, missingInput, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, outputSet, printSchema, references, schema, schemaString, simpleString, statePrefix, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

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

apply, asCode, children, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, map, mapChildren, nodeName, numberedTreeString, otherCopyArgs, 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.LeafNode

children

Methods inherited from interface org.apache.spark.sql.execution.Command

executeCollect

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, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

CreateTableAsSelect

public CreateTableAsSelect(String database,
                   String tableName,
                   org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query,
                   boolean allowExisting,
                   scala.Option<org.apache.hadoop.hive.ql.plan.CreateTableDesc> desc)

Method Detail

database

public String database()

tableName

public String tableName()

query

public org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query()

allowExisting

public boolean allowExisting()

desc

public scala.Option<org.apache.hadoop.hive.ql.plan.CreateTableDesc> desc()

output

public scala.collection.Seq<scala.runtime.Nothing$> output()

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 interface Command

Specified by:

execute in class SparkPlan

argString

public String argString()

Overrides:

argString in class org.apache.spark.sql.catalyst.trees.TreeNode<SparkPlan>