org.apache.spark.sql.catalyst.analysis.resolver
AnalyzerBridgeState
Companion object AnalyzerBridgeState
case class AnalyzerBridgeState(relationsWithResolvedMetadata: RelationsWithResolvedMetadata = new AnalyzerBridgeState.RelationsWithResolvedMetadata, catalogRelationsWithResolvedMetadata: CatalogRelationsWithResolvedMetadata = new AnalyzerBridgeState.CatalogRelationsWithResolvedMetadata, hiveRelationsWithResolvedMetadata: HiveRelationsWithResolvedMetadata = new AnalyzerBridgeState.HiveRelationsWithResolvedMetadata) extends Product with Serializable
The AnalyzerBridgeState is a state passed from legacy Analyzer to the single-pass Resolver. It is used in dual-run mode (when ANALYZER_SINGLE_PASS_RESOLVER_RELATION_BRIDGING_ENABLED is true).
- relationsWithResolvedMetadata
A map from BridgedRelationId to the relations with resolved metadata. It allows us to reuse the relation metadata and avoid duplicate catalog/table lookups.
- catalogRelationsWithResolvedMetadata
A map from UnresolvedCatalogRelation to the relations with resolved metadata. It allows us to reuse the relation metadata and avoid duplicate catalog/table lookups.
- hiveRelationsWithResolvedMetadata
A map from HiveTableRelation to their resolved LogicalRelation counterparts. We cannot import those nodes here because of recursive dependencies, so we rely on overridden LogicalPlan.equals and LogicalPlan.hashCode. Keys are canonicalized to compensate for stats added by DetermineTableStats.
- Alphabetic
- By Inheritance
- AnalyzerBridgeState
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AnalyzerBridgeState(relationsWithResolvedMetadata: RelationsWithResolvedMetadata = new AnalyzerBridgeState.RelationsWithResolvedMetadata, catalogRelationsWithResolvedMetadata: CatalogRelationsWithResolvedMetadata = new AnalyzerBridgeState.CatalogRelationsWithResolvedMetadata, hiveRelationsWithResolvedMetadata: HiveRelationsWithResolvedMetadata = new AnalyzerBridgeState.HiveRelationsWithResolvedMetadata)
- relationsWithResolvedMetadata
A map from BridgedRelationId to the relations with resolved metadata. It allows us to reuse the relation metadata and avoid duplicate catalog/table lookups.
- catalogRelationsWithResolvedMetadata
A map from UnresolvedCatalogRelation to the relations with resolved metadata. It allows us to reuse the relation metadata and avoid duplicate catalog/table lookups.
- hiveRelationsWithResolvedMetadata
A map from HiveTableRelation to their resolved LogicalRelation counterparts. We cannot import those nodes here because of recursive dependencies, so we rely on overridden LogicalPlan.equals and LogicalPlan.hashCode. Keys are canonicalized to compensate for stats added by DetermineTableStats.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addLogicalRelationForHiveRelation(hiveRelation: LogicalPlan, logicalRelation: LogicalPlan): Unit
- def addUnresolvedRelation(unresolvedRelation: UnresolvedRelation, relation: LogicalPlan): Unit
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val catalogRelationsWithResolvedMetadata: CatalogRelationsWithResolvedMetadata
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getLogicalRelationForHiveRelation(hiveRelation: LogicalPlan): Option[LogicalPlan]
- val hiveRelationsWithResolvedMetadata: HiveRelationsWithResolvedMetadata
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val relationsWithResolvedMetadata: RelationsWithResolvedMetadata
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)