Interface LookupCatalog
- All Superinterfaces:
org.apache.spark.internal.Logging
public interface LookupCatalog
extends org.apache.spark.internal.Logging
A trait to encapsulate catalog lookup function and helpful extractors.
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic class
Extract legacy table identifier from a multi-part identifier.static class
Extract legacy table identifier from a multi-part identifier.static class
Extract catalog and identifier from a multi-part name with the current catalog if needed.static class
Extract catalog and identifier from a multi-part name with the current catalog if needed.static class
Extract catalog and namespace from a multi-part name with the current catalog if needed.static class
Extract catalog and namespace from a multi-part name with the current catalog if needed.static class
Extract non-session catalog and identifier from a multi-part identifier.static class
Extract non-session catalog and identifier from a multi-part identifier.static class
Extract session catalog and identifier from a multi-part identifier.static class
Extract session catalog and identifier from a multi-part identifier.Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging
org.apache.spark.internal.Logging.SparkShellLoggingFilter
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$
org.apache.spark.sql.connector.catalog.CatalogManager
Returns the current catalog set.Methods inherited from interface org.apache.spark.internal.Logging
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_, org$apache$spark$internal$Logging$$log__$eq
-
Method Details
-
AsTableIdentifier
LookupCatalog.AsTableIdentifier$ AsTableIdentifier() -
CatalogAndIdentifier
LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier() -
CatalogAndMultipartIdentifier
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier() -
CatalogAndNamespace
LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace() -
NonSessionCatalogAndIdentifier
LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier() -
SessionCatalogAndIdentifier
LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier() -
catalogManager
org.apache.spark.sql.connector.catalog.CatalogManager catalogManager() -
currentCatalog
CatalogPlugin currentCatalog()Returns the current catalog set.- Returns:
- (undocumented)
-