org.apache.spark.sql.hive.execution

Interface CreateHiveTableAsSelectBase

All Superinterfaces:

org.apache.spark.sql.catalyst.plans.logical.Command, org.apache.spark.sql.execution.command.DataWritingCommand

All Known Implementing Classes:

CreateHiveTableAsSelectCommand, OptimizedCreateHiveTableAsSelectCommand

public interface CreateHiveTableAsSelectBase
extends org.apache.spark.sql.execution.command.DataWritingCommand

Method Summary

Modifier and Type	Method and Description
String	argString(int maxFields)
org.apache.spark.sql.execution.command.DataWritingCommand	getWritingCommand(org.apache.spark.sql.catalyst.catalog.SessionCatalog catalog, org.apache.spark.sql.catalyst.catalog.CatalogTable tableDesc, boolean tableExists)
SaveMode	mode()
scala.collection.Seq<String>	outputColumnNames()
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	query()
scala.collection.Seq<Row>	run(SparkSession sparkSession, org.apache.spark.sql.execution.SparkPlan child)
org.apache.spark.sql.catalyst.catalog.CatalogTable	tableDesc()
org.apache.spark.sql.catalyst.TableIdentifier	tableIdentifier()
String	writingCommandClassName()

Methods inherited from interface org.apache.spark.sql.execution.command.DataWritingCommand

$init$, basicWriteJobStatsTracker, children, logicalPlanOutputWithNames, metrics, outputColumns

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

$init$, output

Method Detail

argString

String argString(int maxFields)

getWritingCommand

org.apache.spark.sql.execution.command.DataWritingCommand getWritingCommand(org.apache.spark.sql.catalyst.catalog.SessionCatalog catalog,
                                                                            org.apache.spark.sql.catalyst.catalog.CatalogTable tableDesc,
                                                                            boolean tableExists)

mode

SaveMode mode()

outputColumnNames

scala.collection.Seq<String> outputColumnNames()

Specified by:

outputColumnNames in interface org.apache.spark.sql.execution.command.DataWritingCommand

query

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

Specified by:

query in interface org.apache.spark.sql.execution.command.DataWritingCommand

run

scala.collection.Seq<Row> run(SparkSession sparkSession,
                              org.apache.spark.sql.execution.SparkPlan child)

Specified by:

run in interface org.apache.spark.sql.execution.command.DataWritingCommand

tableDesc

org.apache.spark.sql.catalyst.catalog.CatalogTable tableDesc()

tableIdentifier

org.apache.spark.sql.catalyst.TableIdentifier tableIdentifier()

writingCommandClassName

String writingCommandClassName()