Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.utils |
Modifier and Type | Class and Description |
---|---|
static class |
Column.ComputedColumn
Representation of a computed column.
|
static class |
Column.MetadataColumn
Representation of a metadata column.
|
static class |
Column.PhysicalColumn
Representation of a physical column.
|
Modifier and Type | Method and Description |
---|---|
abstract Column |
Column.copy(DataType newType)
Returns a copy of the column with a replaced
DataType . |
Column |
Column.PhysicalColumn.copy(DataType newDataType) |
Column |
Column.ComputedColumn.copy(DataType newDataType) |
Column |
Column.MetadataColumn.copy(DataType newDataType) |
Modifier and Type | Method and Description |
---|---|
Optional<Column> |
ResolvedSchema.getColumn(int columnIndex)
Returns the
Column instance for the given column index. |
Optional<Column> |
ResolvedSchema.getColumn(String columnName)
Returns the
Column instance for the given column name. |
List<Column> |
ResolvedSchema.getColumns()
Returns all
Column s of this schema. |
Modifier and Type | Method and Description |
---|---|
static ResolvedSchema |
ResolvedSchema.of(Column... columns)
Shortcut for a resolved schema of only columns.
|
Modifier and Type | Method and Description |
---|---|
static ResolvedSchema |
ResolvedSchema.of(List<Column> columns)
Shortcut for a resolved schema of only columns.
|
Constructor and Description |
---|
ResolvedSchema(List<Column> columns,
List<WatermarkSpec> watermarkSpecs,
UniqueConstraint primaryKey) |
Modifier and Type | Method and Description |
---|---|
static int[] |
PrintUtils.columnWidthsByType(List<Column> columns,
int maxColumnWidth,
String nullColumn,
String rowKindColumn)
Try to derive column width based on column types.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.