org.apache.spark.sql.hive.execution

Class InsertIntoHiveTable

Object

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

org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.execution.SparkPlan>

org.apache.spark.sql.execution.SparkPlan

org.apache.spark.sql.hive.execution.InsertIntoHiveTable

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.trees.UnaryNode<org.apache.spark.sql.execution.SparkPlan>, HiveInspectors, scala.Equals, scala.Product

public class InsertIntoHiveTable
extends org.apache.spark.sql.execution.SparkPlan
implements org.apache.spark.sql.execution.UnaryNode, HiveInspectors, scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.sql.hive.HiveInspectors

HiveInspectors.typeInfoConversions

Constructor Summary

Constructors

Constructor and Description
InsertIntoHiveTable(MetastoreRelation table, scala.collection.immutable.Map<String,scala.Option<String>> partition, org.apache.spark.sql.execution.SparkPlan child, boolean overwrite)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.execution.SparkPlan	child()
RDD<org.apache.spark.sql.Row>	execute()
org.apache.spark.sql.Row[]	executeCollect()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
Class<? extends org.apache.hadoop.io.Writable>	outputClass()
boolean	overwrite()
scala.collection.immutable.Map<String,scala.Option<String>>	partition()
void	saveAsHiveFile(RDD<org.apache.spark.sql.Row> rdd, Class<?> valueClass, ShimFileSinkDesc fileSinkConf, SerializableWritable<org.apache.hadoop.mapred.JobConf> conf, SparkHiveWriterContainer writerContainer)
HiveContext	sc()
MetastoreRelation	table()

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

codegenEnabled, executeTake, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, makeCopy, newMutableProjection, newOrdering, newPredicate, newProjection, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_, outputPartitioning, requiredChildDistribution, sparkContext, sqlContext

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, argString, asCode, children, collect, fastEquals, flatMap, foreach, foreachUp, generateTreeString, getNodeNumbered, 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 org.apache.spark.sql.execution.UnaryNode

outputPartitioning

Methods inherited from interface org.apache.spark.sql.catalyst.trees.UnaryNode

children

Methods inherited from interface org.apache.spark.sql.hive.HiveInspectors

inspectorToDataType, javaClassToDataType, toInspector, toInspector, unwrap, wrap, wrap, wrap, wrapperFor

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(MetastoreRelation table,
                   scala.collection.immutable.Map<String,scala.Option<String>> partition,
                   org.apache.spark.sql.execution.SparkPlan child,
                   boolean overwrite)

Method Detail

table

public MetastoreRelation table()

partition

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

child

public org.apache.spark.sql.execution.SparkPlan child()

Specified by:

child in interface org.apache.spark.sql.catalyst.trees.UnaryNode<org.apache.spark.sql.execution.SparkPlan>

overwrite

public boolean overwrite()

sc

public HiveContext sc()

outputClass

public Class<? extends org.apache.hadoop.io.Writable> outputClass()

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.execution.SparkPlan>

saveAsHiveFile

public void saveAsHiveFile(RDD<org.apache.spark.sql.Row> rdd,
                  Class<?> valueClass,
                  ShimFileSinkDesc fileSinkConf,
                  SerializableWritable<org.apache.hadoop.mapred.JobConf> conf,
                  SparkHiveWriterContainer writerContainer)

executeCollect

public org.apache.spark.sql.Row[] executeCollect()

Overrides:

executeCollect in class org.apache.spark.sql.execution.SparkPlan

execute

public RDD<org.apache.spark.sql.Row> execute()

Specified by:

execute in class org.apache.spark.sql.execution.SparkPlan