org.apache.flink.table.planner.utils

Class OperationConverterUtils

java.lang.Object

org.apache.flink.table.planner.utils.OperationConverterUtils

public class OperationConverterUtils
extends Object

Utils methods for converting sql to operations.

Method Summary

Modifier and Type	Method and Description
static List<TableChange>	buildModifyColumnChange(Column oldColumn, Column newColumn, TableChange.ColumnPosition columnPosition)
static TableSchema	changeColumn(TableSchema oldSchema, String oldName, TableColumn newTableColumn, boolean first, String after)
static Operation	convertAddReplaceColumns(ObjectIdentifier tableIdentifier, SqlAddReplaceColumns addReplaceColumns, CatalogTable catalogTable, org.apache.calcite.sql.validate.SqlValidator sqlValidator)
static Operation	convertChangeColumn(ObjectIdentifier tableIdentifier, SqlChangeColumn changeColumn, ResolvedCatalogTable catalogTable, org.apache.calcite.sql.validate.SqlValidator sqlValidator)
static Map<String,String>	extractProperties(org.apache.calcite.sql.SqlNodeList propList)
static String	getComment(SqlTableColumn column)

Methods inherited from class java.lang.Object

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

Method Detail

convertAddReplaceColumns

public static Operation convertAddReplaceColumns(ObjectIdentifier tableIdentifier,
                                                 SqlAddReplaceColumns addReplaceColumns,
                                                 CatalogTable catalogTable,
                                                 org.apache.calcite.sql.validate.SqlValidator sqlValidator)

convertChangeColumn

public static Operation convertChangeColumn(ObjectIdentifier tableIdentifier,
                                            SqlChangeColumn changeColumn,
                                            ResolvedCatalogTable catalogTable,
                                            org.apache.calcite.sql.validate.SqlValidator sqlValidator)

buildModifyColumnChange

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

changeColumn

public static TableSchema changeColumn(TableSchema oldSchema,
                                       String oldName,
                                       TableColumn newTableColumn,
                                       boolean first,
                                       String after)

getComment

@Nullable
public static String getComment(SqlTableColumn column)

extractProperties

public static Map<String,String> extractProperties(org.apache.calcite.sql.SqlNodeList propList)