public class UpdateSchema extends Object
Constructor and Description |
---|
UpdateSchema(org.apache.flink.table.types.logical.RowType rowType,
List<String> partitionKeys,
List<String> primaryKeys,
Map<String,String> options,
String comment) |
Modifier and Type | Method and Description |
---|---|
String |
comment() |
static UpdateSchema |
fromCatalogTable(org.apache.flink.table.catalog.CatalogTable catalogTable) |
Map<String,String> |
options() |
List<String> |
partitionKeys() |
List<String> |
primaryKeys() |
org.apache.flink.table.types.logical.RowType |
rowType() |
org.apache.flink.table.catalog.CatalogTableImpl |
toCatalogTable() |
String |
toString() |
public org.apache.flink.table.types.logical.RowType rowType()
public String comment()
public org.apache.flink.table.catalog.CatalogTableImpl toCatalogTable()
public static UpdateSchema fromCatalogTable(org.apache.flink.table.catalog.CatalogTable catalogTable)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.