Package org.apache.spark.sql.connector.catalog

Class CatalogV2Implicits.IdentifierHelper

Object
org.apache.spark.sql.connector.catalog.CatalogV2Implicits.IdentifierHelper
Enclosing class:
CatalogV2Implicits
public static class CatalogV2Implicits.IdentifierHelper extends Object

  • Constructor Details

    • IdentifierHelper

      public IdentifierHelper(Identifier ident)

  • Method Details

    • asFunctionIdentifier

      public org.apache.spark.sql.catalyst.FunctionIdentifier asFunctionIdentifier()

    • asMultipartIdentifier

      public scala.collection.immutable.Seq<String> asMultipartIdentifier()

    • asTableIdentifier

      public org.apache.spark.sql.catalyst.TableIdentifier asTableIdentifier()

    • asTableIdentifierOpt

      public scala.Option<org.apache.spark.sql.catalyst.TableIdentifier> asTableIdentifierOpt(scala.Option<String> catalogName)
      Tries to convert catalog identifier to the table identifier. Table identifier does not support multiple namespaces (nested namespaces), so if identifier contains nested namespace, conversion cannot be done
      Parameters:
      catalogName - Catalog name. Identifier represents just one object in catalog, so it has no catalog name needed for table identifier creation
      Returns:
      Table identifier if conversion can be done, None otherwise

    • fullyQuoted

      public String fullyQuoted()

    • original

      public String original()

    • quoted

      public String quoted()

    • toQualifiedNameParts

      public scala.collection.immutable.Seq<String> toQualifiedNameParts(CatalogPlugin catalog)