Modifier and Type | Method and Description |
---|---|
default void |
Catalog.alterTable(Identifier identifier,
SchemaChange change,
boolean ignoreIfNotExists)
Modify an existing table from a
SchemaChange . |
Modifier and Type | Method and Description |
---|---|
void |
DelegateCatalog.alterTable(Identifier identifier,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
void |
Catalog.alterTable(Identifier identifier,
List<SchemaChange> changes,
boolean ignoreIfNotExists)
Modify an existing table from
SchemaChange s. |
void |
AbstractCatalog.alterTable(Identifier identifier,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
void |
CachingCatalog.alterTable(Identifier identifier,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
protected void |
FileSystemCatalog.alterTableImpl(Identifier identifier,
List<SchemaChange> changes) |
protected abstract void |
AbstractCatalog.alterTableImpl(Identifier identifier,
List<SchemaChange> changes) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
FlinkCatalog.handleMaterializedTableChange(org.apache.flink.table.catalog.TableChange change,
List<SchemaChange> schemaChanges)
Try handle change related to materialized table.
|
Modifier and Type | Method and Description |
---|---|
protected List<SchemaChange> |
UpdatedDataFieldsProcessFunctionBase.extractSchemaChanges(SchemaManager schemaManager,
List<DataField> updatedDataFields) |
Modifier and Type | Method and Description |
---|---|
protected void |
UpdatedDataFieldsProcessFunctionBase.applySchemaChange(SchemaManager schemaManager,
SchemaChange schemaChange,
Identifier identifier) |
Modifier and Type | Method and Description |
---|---|
protected void |
HiveCatalog.alterTableImpl(Identifier identifier,
List<SchemaChange> changes) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcCatalog.alterTableImpl(Identifier identifier,
List<SchemaChange> changes) |
Modifier and Type | Method and Description |
---|---|
void |
PrivilegedCatalog.alterTable(Identifier identifier,
List<SchemaChange> changes,
boolean ignoreIfNotExists) |
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.UpdateColumnPosition
A SchemaChange to update the field position.
|
static class |
SchemaChange.UpdateColumnType
A SchemaChange to update the field type.
|
static class |
SchemaChange.UpdateComment
A SchemaChange to Update table comment.
|
Modifier and Type | Method and Description |
---|---|
static SchemaChange |
SchemaChange.addColumn(String fieldName,
DataType dataType) |
static SchemaChange |
SchemaChange.addColumn(String fieldName,
DataType dataType,
String comment) |
static SchemaChange |
SchemaChange.addColumn(String fieldName,
DataType dataType,
String comment,
SchemaChange.Move move) |
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.updateColumnComment(String fieldName,
String comment) |
static SchemaChange |
SchemaChange.updateColumnNullability(String[] fieldNames,
boolean newNullability) |
static SchemaChange |
SchemaChange.updateColumnNullability(String fieldName,
boolean newNullability) |
static SchemaChange |
SchemaChange.updateColumnPosition(SchemaChange.Move move) |
static SchemaChange |
SchemaChange.updateColumnType(String fieldName,
DataType newDataType) |
static SchemaChange |
SchemaChange.updateColumnType(String fieldName,
DataType newDataType,
boolean keepNullability) |
static SchemaChange |
SchemaChange.updateComment(String comment) |
Modifier and Type | Method and Description |
---|---|
TableSchema |
SchemaManager.commitChanges(SchemaChange... changes)
Update
SchemaChange s. |
Modifier and Type | Method and Description |
---|---|
TableSchema |
SchemaManager.commitChanges(List<SchemaChange> changes)
Update
SchemaChange s. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.