public class HiveMetastoreCatalog.PreInsertionCasts
extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>
Constructor and Description |
---|
HiveMetastoreCatalog.PreInsertionCasts()
Casts input data to correct data types according to table definition before inserting into
that table.
|
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) |
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
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, log_
public HiveMetastoreCatalog.PreInsertionCasts()
public org.apache.spark.sql.catalyst.plans.logical.LogicalPlan apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
apply
in class org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>
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)