org.apache.spark.sql.hive

Class ResolveHiveSerdeTable

Object

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

org.apache.spark.sql.hive.ResolveHiveSerdeTable

All Implemented Interfaces:

org.apache.spark.internal.Logging

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

Determine the database, serde/format and schema of the Hive serde table, according to the storage properties.

Constructor Summary

Constructors

Constructor and Description
ResolveHiveSerdeTable(SparkSession session)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)

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

initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, ruleName

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.internal.Logging

$init$, initLock, uninitialize

Constructor Detail

ResolveHiveSerdeTable

public ResolveHiveSerdeTable(SparkSession session)

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>