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 scala.collection.immutable.Map<String,String> |
convertTableProperties(scala.collection.immutable.Map<String,String> properties,
scala.collection.immutable.Map<String,String> options,
scala.Option<String> location,
scala.Option<String> comment,
String provider) |
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 boolean |
isSessionCatalog(CatalogPlugin catalog) |
static scala.Option<Table> |
loadTable(CatalogPlugin catalog,
Identifier ident) |
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 boolean isSessionCatalog(CatalogPlugin catalog)
public static scala.collection.immutable.Map<String,String> convertTableProperties(scala.collection.immutable.Map<String,String> properties, scala.collection.immutable.Map<String,String> options, scala.Option<String> location, scala.Option<String> comment, String provider)
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)