Package | Description |
---|---|
org.apache.flink.table.store.file.catalog | |
org.apache.flink.table.store.file.schema | |
org.apache.flink.table.store.hive |
Modifier and Type | Method and Description |
---|---|
void |
FileSystemCatalog.alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
void |
Catalog.alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
List<SchemaChange> changes,
boolean ignoreIfNotExists)
Modify an existing table from
SchemaChange s. |
Modifier and Type | Class and Description |
---|---|
static class |
SchemaChange.AddColumn
A SchemaChange to add a field.
|
static class |
SchemaChange.DropColumn
A SchemaChange to drop a field.
|
static class |
SchemaChange.RemoveOption
A SchemaChange to remove a table option.
|
static class |
SchemaChange.RenameColumn
A SchemaChange to rename a field.
|
static class |
SchemaChange.SetOption
A SchemaChange to set a table option.
|
static class |
SchemaChange.UpdateColumnComment
A SchemaChange to update the (nested) field comment.
|
static class |
SchemaChange.UpdateColumnNullability
A SchemaChange to update the (nested) field nullability.
|
static class |
SchemaChange.UpdateColumnType
A SchemaChange to update the field type.
|
Modifier and Type | Method and Description |
---|---|
static SchemaChange |
SchemaChange.addColumn(String fieldName,
org.apache.flink.table.types.logical.LogicalType logicalType) |
static SchemaChange |
SchemaChange.addColumn(String fieldName,
org.apache.flink.table.types.logical.LogicalType logicalType,
String comment) |
static SchemaChange |
SchemaChange.dropColumn(String fieldName) |
static SchemaChange |
SchemaChange.removeOption(String key) |
static SchemaChange |
SchemaChange.renameColumn(String fieldName,
String newName) |
static SchemaChange |
SchemaChange.setOption(String key,
String value) |
static SchemaChange |
SchemaChange.updateColumnComment(String[] fieldNames,
String comment) |
static SchemaChange |
SchemaChange.updateColumnNullability(String[] fieldNames,
boolean newNullability) |
static SchemaChange |
SchemaChange.updateColumnType(String fieldName,
org.apache.flink.table.types.logical.LogicalType newLogicalType) |
Modifier and Type | Method and Description |
---|---|
TableSchema |
SchemaManager.commitChanges(List<SchemaChange> changes)
Create
SchemaChange s. |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.