org.apache.spark.sql.hive

Class InsertIntoHiveTable

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.hive.InsertIntoHiveTable

All Implemented Interfaces:

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

public class InsertIntoHiveTable
extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
implements scala.Product, scala.Serializable

A logical plan representing insertion into Hive table. This plan ignores nullability of ArrayType, MapType, StructType unlike InsertIntoTable because Hive table doesn't have nullability for ARRAY, MAP, STRUCT types.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
InsertIntoHiveTable(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan table, scala.collection.immutable.Map<String,scala.Option<String>> partition, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child, boolean overwrite)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	child()
scala.collection.immutable.List<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>	children()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
boolean	overwrite()
scala.collection.immutable.Map<String,scala.Option<String>>	partition()
boolean	resolved()
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	table()

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, resolveChildren, 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

InsertIntoHiveTable

public InsertIntoHiveTable(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan table,
                   scala.collection.immutable.Map<String,scala.Option<String>> partition,
                   org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child,
                   boolean overwrite)

Method Detail

table

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

partition

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

child

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

overwrite

public boolean overwrite()

children

public scala.collection.immutable.List<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> children()

Specified by:

children in class org.apache.spark.sql.catalyst.trees.TreeNode<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

output

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()

Specified by:

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

resolved

public boolean resolved()

Overrides:

resolved in class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan