org.apache.spark.sql.hive

Class HiveMetastoreCatalog.PreInsertionCasts

Object

org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

org.apache.spark.sql.hive.HiveMetastoreCatalog.PreInsertionCasts

All Implemented Interfaces:

Logging

Enclosing class:

HiveMetastoreCatalog

public class HiveMetastoreCatalog.PreInsertionCasts
extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

Constructor Summary

Constructors

Constructor and Description
HiveMetastoreCatalog.PreInsertionCasts() Casts input data to correct data types according to table definition before inserting into that table.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	castChildOutput(org.apache.spark.sql.catalyst.plans.logical.InsertIntoTable p, MetastoreRelation table, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child)

Methods inherited from class org.apache.spark.sql.catalyst.rules.Rule

isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_, ruleName

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, log_

Constructor Detail

HiveMetastoreCatalog.PreInsertionCasts

public HiveMetastoreCatalog.PreInsertionCasts()

Casts input data to correct data types according to table definition before inserting into that table.

Method Detail

apply

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

Specified by:

apply in class org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

castChildOutput

public org.apache.spark.sql.catalyst.plans.logical.LogicalPlan castChildOutput(org.apache.spark.sql.catalyst.plans.logical.InsertIntoTable p,
                                                                      MetastoreRelation table,
                                                                      org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child)