org.apache.flink.table.planner.utils

Class TableSchemaUtils

java.lang.Object

org.apache.flink.table.planner.utils.TableSchemaUtils

public class TableSchemaUtils
extends Object

Utils methods for converting table schema.

Method Summary

Modifier and Type	Method and Description
static List<TableChange>	buildModifyColumnChange(Column oldColumn, Column newColumn, TableChange.ColumnPosition columnPosition) This method is copied from OperationConverterUtils#buildModifyColumnChange located in flink-table-planner, and should be synchronized if OperationConverterUtils#buildModifyColumnChange changes in the the future.
static ResolvedSchema	changeColumn(ResolvedSchema oldSchema, String oldName, Column newTableColumn, boolean first, String after) Change a column in the old table schema and return the updated table schema.
static ResolvedSchema	resolvedSchema(org.apache.calcite.rel.RelNode calciteTree)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

resolvedSchema

public static ResolvedSchema resolvedSchema(org.apache.calcite.rel.RelNode calciteTree)

buildModifyColumnChange

public static List<TableChange> buildModifyColumnChange(Column oldColumn,
                                                        Column newColumn,
                                                        @Nullable
                                                        TableChange.ColumnPosition columnPosition)

This method is copied from OperationConverterUtils#buildModifyColumnChange located in flink-table-planner, and should be synchronized if OperationConverterUtils#buildModifyColumnChange changes in the the future.

changeColumn

public static ResolvedSchema changeColumn(ResolvedSchema oldSchema,
                                          String oldName,
                                          Column newTableColumn,
                                          boolean first,
                                          String after)

Change a column in the old table schema and return the updated table schema.