org.apache.spark.sql.sources

Class CreateTempTableUsingAsSelect

Object

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

org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

org.apache.spark.sql.catalyst.plans.logical.LeafNode

org.apache.spark.sql.catalyst.plans.logical.Command

org.apache.spark.sql.sources.CreateTempTableUsingAsSelect

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.trees.LeafNode<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>, org.apache.spark.sql.execution.RunnableCommand, scala.Equals, scala.Product

public class CreateTempTableUsingAsSelect
extends org.apache.spark.sql.catalyst.plans.logical.Command
implements org.apache.spark.sql.execution.RunnableCommand, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CreateTempTableUsingAsSelect(String tableName, String provider, SaveMode mode, scala.collection.immutable.Map<String,String> options, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query)

Method Summary

Methods

Modifier and Type	Method and Description
SaveMode	mode()
scala.collection.immutable.Map<String,String>	options()
String	provider()
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	query()
scala.collection.Seq<Row>	run(SQLContext sqlContext)
String	tableName()

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.Command

output

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.LeafNode

children

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

childrenResolved, cleanArgs, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_, org$apache$spark$sql$catalyst$plans$logical$LogicalPlan$$resolveAsColumn, org$apache$spark$sql$catalyst$plans$logical$LogicalPlan$$resolveAsTableColumn, resolve, resolve, resolve$default$3, resolveChildren, resolveChildren$default$3, resolved, resolveGetField, sameResult, statePrefix, statistics

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, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

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

apply, argString, asCode, collect, fastEquals, flatMap, foreach, foreachUp, generateTreeString, getNodeNumbered, makeCopy, map, mapChildren, nodeName, numberedTreeString, origin, 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 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

CreateTempTableUsingAsSelect

public CreateTempTableUsingAsSelect(String tableName,
                            String provider,
                            SaveMode mode,
                            scala.collection.immutable.Map<String,String> options,
                            org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query)

Method Detail

tableName

public String tableName()

provider

public String provider()

mode

public SaveMode mode()

options

public scala.collection.immutable.Map<String,String> options()

query

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

run

public scala.collection.Seq<Row> run(SQLContext sqlContext)

Specified by:

run in interface org.apache.spark.sql.execution.RunnableCommand