org.apache.spark.sql.hive.execution

Class InsertIntoHiveTable

java.lang.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, org.apache.spark.sql.execution.UnaryExecNode, scala.Equals, scala.Product

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

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	allAttributes()
static BaseType	apply(int number)
static java.lang.String	argString()
static java.lang.String	asCode()
abstract static boolean	canEqual(java.lang.Object that)
protected static PlanType	canonicalized()
org.apache.spark.sql.execution.SparkPlan	child()
static scala.collection.Seq<org.apache.spark.sql.execution.SparkPlan>	children()
protected static scala.collection.Seq<java.lang.Object>	cleanArgs()
static <B> scala.collection.Seq<B>	collect(scala.PartialFunction<BaseType,B> pf)
static <B> scala.Option<B>	collectFirst(scala.PartialFunction<BaseType,B> pf)
static org.apache.spark.sql.catalyst.expressions.ExpressionSet	constraints()
static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.trees.TreeNode<?>>	containsChild()
protected RDD<org.apache.spark.sql.catalyst.InternalRow>	doExecute()
protected static <T> Broadcast<T>	doExecuteBroadcast()
protected static void	doPrepare()
abstract static boolean	equals(java.lang.Object that)
static RDD<org.apache.spark.sql.catalyst.InternalRow>	execute()
static <T> Broadcast<T>	executeBroadcast()
org.apache.spark.sql.catalyst.InternalRow[]	executeCollect()
static Row[]	executeCollectPublic()
protected static <T> T	executeQuery(scala.Function0<T> query)
static org.apache.spark.sql.catalyst.InternalRow[]	executeTake(int n)
static scala.collection.Iterator<org.apache.spark.sql.catalyst.InternalRow>	executeToIterator()
static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	expressions()
static boolean	fastEquals(org.apache.spark.sql.catalyst.trees.TreeNode<?> other)
static scala.Option<BaseType>	find(scala.Function1<BaseType,java.lang.Object> f)
static <A> scala.collection.Seq<A>	flatMap(scala.Function1<BaseType,scala.collection.TraversableOnce<A>> f)
static void	foreach(scala.Function1<BaseType,scala.runtime.BoxedUnit> f)
static void	foreachUp(scala.Function1<BaseType,scala.runtime.BoxedUnit> f)
static scala.collection.mutable.StringBuilder	generateTreeString(int depth, scala.collection.Seq<java.lang.Object> lastChildren, scala.collection.mutable.StringBuilder builder)
org.apache.hadoop.fs.Path	getExternalTmpPath(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration hadoopConf)
org.apache.hadoop.fs.Path	getExtTmpPathRelTo(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration hadoopConf)
protected static BaseType	getNodeNumbered(org.apache.spark.sql.catalyst.trees.MutableInt number)
protected static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression>	getRelevantConstraints(scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression> constraints)
static int	hashCode()
boolean	ifNotExists()
void	initializeLogging(boolean isInterpreter)
protected static void	initializeLogIfNecessary(boolean isInterpreter)
static scala.collection.Seq<PlanType>	innerChildren()
static org.apache.spark.sql.catalyst.expressions.AttributeSet	inputSet()
protected static boolean	isTraceEnabled()
protected static scala.collection.immutable.List<scala.Tuple2<java.lang.String,org.json4s.JsonAST.JValue>>	jsonFields()
org.slf4j.Logger	log_()
protected static org.slf4j.Logger	log()
protected static void	logDebug(scala.Function0<java.lang.String> msg)
protected static void	logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logError(scala.Function0<java.lang.String> msg)
protected static void	logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logInfo(scala.Function0<java.lang.String> msg)
protected static void	logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static java.lang.String	logName()
protected static void	logTrace(scala.Function0<java.lang.String> msg)
protected static void	logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logWarning(scala.Function0<java.lang.String> msg)
protected static void	logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
static org.apache.spark.sql.execution.SparkPlan	makeCopy(java.lang.Object[] newArgs)
static <A> scala.collection.Seq<A>	map(scala.Function1<BaseType,A> f)
static BaseType	mapChildren(scala.Function1<BaseType,BaseType> f)
static org.apache.spark.sql.catalyst.expressions.AttributeSet	missingInput()
protected static org.apache.spark.sql.catalyst.expressions.MutableProjection	newMutableProjection(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema, boolean useSubexprElimination)
protected static boolean	newMutableProjection$default$3()
protected static scala.math.Ordering<org.apache.spark.sql.catalyst.InternalRow>	newNaturalAscendingOrdering(scala.collection.Seq<DataType> dataTypes)
protected static scala.math.Ordering<org.apache.spark.sql.catalyst.InternalRow>	newOrdering(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> order, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema)
protected static scala.Function1<org.apache.spark.sql.catalyst.InternalRow,java.lang.Object>	newPredicate(org.apache.spark.sql.catalyst.expressions.Expression expression, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema)
static java.lang.String	nodeName()
static java.lang.String	numberedTreeString()
static org.apache.spark.sql.catalyst.trees.Origin	origin()
protected static scala.collection.Seq<java.lang.Object>	otherCopyArgs()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder>	outputOrdering()
static org.apache.spark.sql.catalyst.plans.physical.Partitioning	outputPartitioning()
static org.apache.spark.sql.catalyst.expressions.AttributeSet	outputSet()
boolean	overwrite()
scala.collection.immutable.Map<java.lang.String,scala.Option<java.lang.String>>	partition()
static void	prepare()
protected static void	prepareSubqueries()
static java.lang.String	prettyJson()
static void	printSchema()
static org.apache.spark.sql.catalyst.expressions.AttributeSet	producedAttributes()
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
static org.apache.spark.sql.catalyst.expressions.AttributeSet	references()
static scala.collection.Seq<org.apache.spark.sql.catalyst.plans.physical.Distribution>	requiredChildDistribution()
static scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder>>	requiredChildOrdering()
static boolean	sameResult(PlanType plan)
static StructType	schema()
static java.lang.String	schemaString()
protected scala.collection.Seq<org.apache.spark.sql.catalyst.InternalRow>	sideEffectResult() Inserts all the rows in the table into Hive.
static java.lang.String	simpleString()
protected static SparkContext	sparkContext()
protected static SQLContext	sqlContext()
java.lang.String	stagingDir()
protected static java.lang.String	statePrefix()
protected static scala.collection.Iterator<java.lang.Object>	stringArgs()
static boolean	subexpressionEliminationEnabled()
static scala.collection.Seq<PlanType>	subqueries()
org.apache.spark.sql.hive.MetastoreRelation	table()
static java.lang.String	toJSON()
static java.lang.String	toString()
static BaseType	transform(scala.PartialFunction<BaseType,BaseType> rule)
static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>	transformAllExpressions(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)
protected static BaseType	transformChildren(scala.PartialFunction<BaseType,BaseType> rule, scala.Function2<BaseType,scala.PartialFunction<BaseType,BaseType>,BaseType> nextOperation)
static BaseType	transformDown(scala.PartialFunction<BaseType,BaseType> rule)
static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>	transformExpressions(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)
static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>	transformExpressionsDown(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)
static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>	transformExpressionsUp(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)
static BaseType	transformUp(scala.PartialFunction<BaseType,BaseType> rule)
protected static scala.collection.Seq<BaseType>	treeChildren()
static java.lang.String	treeString()
protected static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression>	validConstraints()
protected static void	waitForSubqueries()
static BaseType	withNewChildren(scala.collection.Seq<BaseType> newChildren)

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

doExecuteBroadcast, doPrepare, execute, executeBroadcast, executeCollectPublic, executeQuery, executeTake, executeToIterator, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, longMetric, makeCopy, metadata, metrics, newMutableProjection, newMutableProjection$default$3, newNaturalAscendingOrdering, newOrdering, newPredicate, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, org$apache$spark$sql$execution$SparkPlan$$decodeUnsafeRows, org$apache$spark$sql$execution$SparkPlan$$subqueryResults, outputOrdering, outputPartitioning, prepare, prepareSubqueries, requiredChildDistribution, requiredChildOrdering, resetMetrics, sparkContext, sqlContext, subexpressionEliminationEnabled, waitForSubqueries

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

allAttributes, canonicalized, cleanArgs, constraints, expressions, getRelevantConstraints, innerChildren, inputSet, missingInput, org$apache$spark$sql$catalyst$plans$QueryPlan$$cleanArg$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$recursiveTransform$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$recursiveTransform$2, org$apache$spark$sql$catalyst$plans$QueryPlan$$scanNullIntolerantExpr, org$apache$spark$sql$catalyst$plans$QueryPlan$$seqToExpressions$1, outputSet, printSchema, producedAttributes, references, sameResult, schema, schemaString, simpleString, statePrefix, subqueries, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp, validConstraints

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

apply, argString, asCode, children, collect, collectFirst, containsChild, fastEquals, find, flatMap, foreach, foreachUp, fromJSON, generateTreeString, getNodeNumbered, hashCode, jsonFields, map, mapChildren, nodeName, numberedTreeString, org$apache$spark$sql$catalyst$trees$TreeNode$$collectJsonValue$1, org$apache$spark$sql$catalyst$trees$TreeNode$$parseToJson, origin, otherCopyArgs, prettyJson, productIterator, productPrefix, stringArgs, toJSON, toString, transform, transformChildren, transformDown, transformUp, treeChildren, treeString, withNewChildren

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait

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

children, outputPartitioning

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

InsertIntoHiveTable

public InsertIntoHiveTable(org.apache.spark.sql.hive.MetastoreRelation table,
                   scala.collection.immutable.Map<java.lang.String,scala.Option<java.lang.String>> partition,
                   org.apache.spark.sql.execution.SparkPlan child,
                   boolean overwrite,
                   boolean ifNotExists)

Method Detail

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

origin

public static org.apache.spark.sql.catalyst.trees.Origin origin()

containsChild

public static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.trees.TreeNode<?>> containsChild()

hashCode

public static int hashCode()

fastEquals

public static boolean fastEquals(org.apache.spark.sql.catalyst.trees.TreeNode<?> other)

find

public static scala.Option<BaseType> find(scala.Function1<BaseType,java.lang.Object> f)

foreach

public static void foreach(scala.Function1<BaseType,scala.runtime.BoxedUnit> f)

foreachUp

public static void foreachUp(scala.Function1<BaseType,scala.runtime.BoxedUnit> f)

map

public static <A> scala.collection.Seq<A> map(scala.Function1<BaseType,A> f)

flatMap

public static <A> scala.collection.Seq<A> flatMap(scala.Function1<BaseType,scala.collection.TraversableOnce<A>> f)

collect

public static <B> scala.collection.Seq<B> collect(scala.PartialFunction<BaseType,B> pf)

collectFirst

public static <B> scala.Option<B> collectFirst(scala.PartialFunction<BaseType,B> pf)

mapChildren

public static BaseType mapChildren(scala.Function1<BaseType,BaseType> f)

withNewChildren

public static BaseType withNewChildren(scala.collection.Seq<BaseType> newChildren)

transform

public static BaseType transform(scala.PartialFunction<BaseType,BaseType> rule)

transformDown

public static BaseType transformDown(scala.PartialFunction<BaseType,BaseType> rule)

transformUp

public static BaseType transformUp(scala.PartialFunction<BaseType,BaseType> rule)

transformChildren

protected static BaseType transformChildren(scala.PartialFunction<BaseType,BaseType> rule,
                         scala.Function2<BaseType,scala.PartialFunction<BaseType,BaseType>,BaseType> nextOperation)

otherCopyArgs

protected static scala.collection.Seq<java.lang.Object> otherCopyArgs()

nodeName

public static java.lang.String nodeName()

stringArgs

protected static scala.collection.Iterator<java.lang.Object> stringArgs()

argString

public static java.lang.String argString()

toString

public static java.lang.String toString()

treeString

public static java.lang.String treeString()

numberedTreeString

public static java.lang.String numberedTreeString()

apply

public static BaseType apply(int number)

getNodeNumbered

protected static BaseType getNodeNumbered(org.apache.spark.sql.catalyst.trees.MutableInt number)

treeChildren

protected static scala.collection.Seq<BaseType> treeChildren()

generateTreeString

public static scala.collection.mutable.StringBuilder generateTreeString(int depth,
                                                        scala.collection.Seq<java.lang.Object> lastChildren,
                                                        scala.collection.mutable.StringBuilder builder)

asCode

public static java.lang.String asCode()

toJSON

public static java.lang.String toJSON()

prettyJson

public static java.lang.String prettyJson()

jsonFields

protected static scala.collection.immutable.List<scala.Tuple2<java.lang.String,org.json4s.JsonAST.JValue>> jsonFields()

getRelevantConstraints

protected static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression> getRelevantConstraints(scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression> constraints)

constraints

public static org.apache.spark.sql.catalyst.expressions.ExpressionSet constraints()

validConstraints

protected static scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Expression> validConstraints()

outputSet

public static org.apache.spark.sql.catalyst.expressions.AttributeSet outputSet()

references

public static org.apache.spark.sql.catalyst.expressions.AttributeSet references()

inputSet

public static org.apache.spark.sql.catalyst.expressions.AttributeSet inputSet()

producedAttributes

public static org.apache.spark.sql.catalyst.expressions.AttributeSet producedAttributes()

missingInput

public static org.apache.spark.sql.catalyst.expressions.AttributeSet missingInput()

transformExpressions

public static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType> transformExpressions(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)

transformExpressionsDown

public static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType> transformExpressionsDown(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)

transformExpressionsUp

public static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType> transformExpressionsUp(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)

transformAllExpressions

public static org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType> transformAllExpressions(scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> rule)

expressions

public static final scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions()

schema

public static StructType schema()

schemaString

public static java.lang.String schemaString()

printSchema

public static void printSchema()

statePrefix

protected static java.lang.String statePrefix()

simpleString

public static java.lang.String simpleString()

subqueries

public static scala.collection.Seq<PlanType> subqueries()

innerChildren

public static scala.collection.Seq<PlanType> innerChildren()

canonicalized

protected static PlanType canonicalized()

sameResult

public static boolean sameResult(PlanType plan)

allAttributes

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

cleanArgs

protected static scala.collection.Seq<java.lang.Object> cleanArgs()

logName

protected static java.lang.String logName()

log

protected static org.slf4j.Logger log()

logInfo

protected static void logInfo(scala.Function0<java.lang.String> msg)

logDebug

protected static void logDebug(scala.Function0<java.lang.String> msg)

logTrace

protected static void logTrace(scala.Function0<java.lang.String> msg)

logWarning

protected static void logWarning(scala.Function0<java.lang.String> msg)

logError

protected static void logError(scala.Function0<java.lang.String> msg)

logInfo

protected static void logInfo(scala.Function0<java.lang.String> msg,
           java.lang.Throwable throwable)

logDebug

protected static void logDebug(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

logTrace

protected static void logTrace(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

logWarning

protected static void logWarning(scala.Function0<java.lang.String> msg,
              java.lang.Throwable throwable)

logError

protected static void logError(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

isTraceEnabled

protected static boolean isTraceEnabled()

initializeLogIfNecessary

protected static void initializeLogIfNecessary(boolean isInterpreter)

sqlContext

protected static final SQLContext sqlContext()

sparkContext

protected static SparkContext sparkContext()

subexpressionEliminationEnabled

public static boolean subexpressionEliminationEnabled()

makeCopy

public static org.apache.spark.sql.execution.SparkPlan makeCopy(java.lang.Object[] newArgs)

requiredChildDistribution

public static scala.collection.Seq<org.apache.spark.sql.catalyst.plans.physical.Distribution> requiredChildDistribution()

outputOrdering

public static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> outputOrdering()

requiredChildOrdering

public static scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder>> requiredChildOrdering()

execute

public static final RDD<org.apache.spark.sql.catalyst.InternalRow> execute()

executeBroadcast

public static final <T> Broadcast<T> executeBroadcast()

executeQuery

protected static final <T> T executeQuery(scala.Function0<T> query)

prepareSubqueries

protected static void prepareSubqueries()

waitForSubqueries

protected static void waitForSubqueries()

prepare

public static final void prepare()

doPrepare

protected static void doPrepare()

doExecuteBroadcast

protected static <T> Broadcast<T> doExecuteBroadcast()

executeToIterator

public static scala.collection.Iterator<org.apache.spark.sql.catalyst.InternalRow> executeToIterator()

executeCollectPublic

public static Row[] executeCollectPublic()

executeTake

public static org.apache.spark.sql.catalyst.InternalRow[] executeTake(int n)

newMutableProjection

protected static org.apache.spark.sql.catalyst.expressions.MutableProjection newMutableProjection(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions,
                                                                               scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema,
                                                                               boolean useSubexprElimination)

newPredicate

protected static scala.Function1<org.apache.spark.sql.catalyst.InternalRow,java.lang.Object> newPredicate(org.apache.spark.sql.catalyst.expressions.Expression expression,
                                                                                       scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema)

newOrdering

protected static scala.math.Ordering<org.apache.spark.sql.catalyst.InternalRow> newOrdering(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> order,
                                                                         scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputSchema)

newNaturalAscendingOrdering

protected static scala.math.Ordering<org.apache.spark.sql.catalyst.InternalRow> newNaturalAscendingOrdering(scala.collection.Seq<DataType> dataTypes)

newMutableProjection$default$3

protected static boolean newMutableProjection$default$3()

children

public static scala.collection.Seq<org.apache.spark.sql.execution.SparkPlan> children()

outputPartitioning

public static org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()

table

public org.apache.spark.sql.hive.MetastoreRelation table()

partition

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

child

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

Specified by:

child in interface org.apache.spark.sql.execution.UnaryExecNode

overwrite

public boolean overwrite()

ifNotExists

public boolean ifNotExists()

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>

stagingDir

public java.lang.String stagingDir()

getExternalTmpPath

public org.apache.hadoop.fs.Path getExternalTmpPath(org.apache.hadoop.fs.Path path,
                                           org.apache.hadoop.conf.Configuration hadoopConf)

getExtTmpPathRelTo

public org.apache.hadoop.fs.Path getExtTmpPathRelTo(org.apache.hadoop.fs.Path path,
                                           org.apache.hadoop.conf.Configuration hadoopConf)

sideEffectResult

protected scala.collection.Seq<org.apache.spark.sql.catalyst.InternalRow> sideEffectResult()

Inserts all the rows in the table into Hive. Row objects are properly serialized with the org.apache.hadoop.hive.serde2.SerDe and the org.apache.hadoop.mapred.OutputFormat provided by the table definition.

Note: this is run once and then kept to avoid double insertions.

Returns:

(undocumented)

executeCollect

public org.apache.spark.sql.catalyst.InternalRow[] executeCollect()

Overrides:

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

doExecute

protected RDD<org.apache.spark.sql.catalyst.InternalRow> doExecute()

Specified by:

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

log_

public org.slf4j.Logger log_()

initializeLogging

public void initializeLogging(boolean isInterpreter)