public class CatalogV2Util
extends Object
Constructor and Description |
---|
CatalogV2Util() |
Modifier and Type | Method and Description |
---|---|
static scala.collection.immutable.Map<String,String> |
applyNamespaceChanges(scala.collection.immutable.Map<String,String> properties,
scala.collection.Seq<NamespaceChange> changes)
Apply properties changes to a map and return the result.
|
static java.util.Map<String,String> |
applyNamespaceChanges(java.util.Map<String,String> properties,
scala.collection.Seq<NamespaceChange> changes)
Apply properties changes to a Java map and return the result.
|
static scala.collection.immutable.Map<String,String> |
applyPropertiesChanges(scala.collection.immutable.Map<String,String> properties,
scala.collection.Seq<TableChange> changes)
Apply properties changes to a map and return the result.
|
static java.util.Map<String,String> |
applyPropertiesChanges(java.util.Map<String,String> properties,
scala.collection.Seq<TableChange> changes)
Apply properties changes to a Java map and return the result.
|
static StructType |
applySchemaChanges(StructType schema,
scala.collection.Seq<TableChange> changes)
Apply schema changes to a schema and return the result.
|
static void |
assertNoNullTypeInSchema(StructType schema) |
static scala.collection.immutable.Map<String,String> |
convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.CreateTableAsSelectStatement c) |
static scala.collection.immutable.Map<String,String> |
convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.CreateTableStatement c) |
static scala.collection.immutable.Map<String,String> |
convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.ReplaceTableAsSelectStatement r) |
static scala.collection.immutable.Map<String,String> |
convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.ReplaceTableStatement r) |
static org.apache.spark.sql.catalyst.plans.logical.AlterTable |
createAlterTable(scala.collection.Seq<String> originalNameParts,
CatalogPlugin catalog,
scala.collection.Seq<String> tableName,
scala.collection.Seq<TableChange> changes) |
static void |
failNullType(DataType dt) |
static TableCatalog |
getTableProviderCatalog(SupportsCatalogOptions provider,
org.apache.spark.sql.connector.catalog.CatalogManager catalogManager,
CaseInsensitiveStringMap options) |
static boolean |
isSessionCatalog(CatalogPlugin catalog) |
static scala.Option<org.apache.spark.sql.catalyst.analysis.NamedRelation> |
loadRelation(CatalogPlugin catalog,
Identifier ident) |
static scala.Option<Table> |
loadTable(CatalogPlugin catalog,
Identifier ident) |
static scala.collection.Seq<String> |
NAMESPACE_RESERVED_PROPERTIES()
The list of reserved namespace properties, which can not be removed or changed directly by
the syntax:
{{
ALTER NAMESPACE ...
|
static scala.collection.Seq<String> |
TABLE_RESERVED_PROPERTIES()
The list of reserved table properties, which can not be removed or changed directly by
the syntax:
{{
ALTER TABLE ...
|
static scala.collection.immutable.Map<String,String> |
withDefaultOwnership(scala.collection.immutable.Map<String,String> properties) |
public static scala.collection.Seq<String> TABLE_RESERVED_PROPERTIES()
They need specific syntax to modify
public static scala.collection.Seq<String> NAMESPACE_RESERVED_PROPERTIES()
They need specific syntax to modify
public static scala.collection.immutable.Map<String,String> applyNamespaceChanges(scala.collection.immutable.Map<String,String> properties, scala.collection.Seq<NamespaceChange> changes)
properties
- (undocumented)changes
- (undocumented)public static java.util.Map<String,String> applyNamespaceChanges(java.util.Map<String,String> properties, scala.collection.Seq<NamespaceChange> changes)
properties
- (undocumented)changes
- (undocumented)public static scala.collection.immutable.Map<String,String> applyPropertiesChanges(scala.collection.immutable.Map<String,String> properties, scala.collection.Seq<TableChange> changes)
properties
- (undocumented)changes
- (undocumented)public static java.util.Map<String,String> applyPropertiesChanges(java.util.Map<String,String> properties, scala.collection.Seq<TableChange> changes)
properties
- (undocumented)changes
- (undocumented)public static StructType applySchemaChanges(StructType schema, scala.collection.Seq<TableChange> changes)
schema
- (undocumented)changes
- (undocumented)public static scala.Option<Table> loadTable(CatalogPlugin catalog, Identifier ident)
public static scala.Option<org.apache.spark.sql.catalyst.analysis.NamedRelation> loadRelation(CatalogPlugin catalog, Identifier ident)
public static boolean isSessionCatalog(CatalogPlugin catalog)
public static scala.collection.immutable.Map<String,String> convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.CreateTableStatement c)
public static scala.collection.immutable.Map<String,String> convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.CreateTableAsSelectStatement c)
public static scala.collection.immutable.Map<String,String> convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.ReplaceTableStatement r)
public static scala.collection.immutable.Map<String,String> convertTableProperties(org.apache.spark.sql.catalyst.plans.logical.ReplaceTableAsSelectStatement r)
public static scala.collection.immutable.Map<String,String> withDefaultOwnership(scala.collection.immutable.Map<String,String> properties)
public static org.apache.spark.sql.catalyst.plans.logical.AlterTable createAlterTable(scala.collection.Seq<String> originalNameParts, CatalogPlugin catalog, scala.collection.Seq<String> tableName, scala.collection.Seq<TableChange> changes)
public static TableCatalog getTableProviderCatalog(SupportsCatalogOptions provider, org.apache.spark.sql.connector.catalog.CatalogManager catalogManager, CaseInsensitiveStringMap options)
public static void failNullType(DataType dt)
public static void assertNoNullTypeInSchema(StructType schema)