public interface SchemaChange
Modifier and Type | Interface 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 |
addColumn(String fieldName,
org.apache.flink.table.types.logical.LogicalType logicalType) |
static SchemaChange |
addColumn(String fieldName,
org.apache.flink.table.types.logical.LogicalType logicalType,
String comment) |
static SchemaChange |
dropColumn(String fieldName) |
static SchemaChange |
removeOption(String key) |
static SchemaChange |
renameColumn(String fieldName,
String newName) |
static SchemaChange |
setOption(String key,
String value) |
static SchemaChange |
updateColumnComment(String[] fieldNames,
String comment) |
static SchemaChange |
updateColumnNullability(String[] fieldNames,
boolean newNullability) |
static SchemaChange |
updateColumnType(String fieldName,
org.apache.flink.table.types.logical.LogicalType newLogicalType) |
static SchemaChange setOption(String key, String value)
static SchemaChange removeOption(String key)
static SchemaChange addColumn(String fieldName, org.apache.flink.table.types.logical.LogicalType logicalType)
static SchemaChange addColumn(String fieldName, org.apache.flink.table.types.logical.LogicalType logicalType, String comment)
static SchemaChange renameColumn(String fieldName, String newName)
static SchemaChange dropColumn(String fieldName)
static SchemaChange updateColumnType(String fieldName, org.apache.flink.table.types.logical.LogicalType newLogicalType)
static SchemaChange updateColumnNullability(String[] fieldNames, boolean newNullability)
static SchemaChange updateColumnComment(String[] fieldNames, String comment)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.