Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.planner.utils | |
org.apache.flink.table.utils |
Modifier and Type | Class and Description |
---|---|
static class |
TableColumn.ComputedColumn
Deprecated.
Representation of a computed column.
|
static class |
TableColumn.MetadataColumn
Deprecated.
Representation of a metadata column.
|
static class |
TableColumn.PhysicalColumn
Deprecated.
Representation of a physical column.
|
Modifier and Type | Method and Description |
---|---|
static TableColumn |
TableColumn.of(String name,
DataType type)
Deprecated.
Use
physical(String, DataType) instead. |
static TableColumn |
TableColumn.of(String name,
DataType type,
String expression)
Deprecated.
Use
computed(String, DataType, String) instead. |
Modifier and Type | Method and Description |
---|---|
Optional<TableColumn> |
TableSchema.getTableColumn(int fieldIndex)
Deprecated.
Returns the
TableColumn instance for the given field index. |
Optional<TableColumn> |
TableSchema.getTableColumn(String fieldName)
Deprecated.
Returns the
TableColumn instance for the given field name. |
List<TableColumn> |
TableSchema.getTableColumns()
Deprecated.
Returns all the
TableColumn s for this table schema. |
Modifier and Type | Method and Description |
---|---|
TableSchema.Builder |
TableSchema.Builder.add(TableColumn column)
Adds a
TableColumn to this builder. |
Modifier and Type | Method and Description |
---|---|
static TableSchema |
OperationConverterUtils.changeColumn(TableSchema oldSchema,
String oldName,
TableColumn newTableColumn,
boolean first,
String after) |
Modifier and Type | Method and Description |
---|---|
static int[] |
TypeMappingUtils.computePhysicalIndices(List<TableColumn> logicalColumns,
DataType physicalType,
java.util.function.Function<String,String> nameRemapping)
Computes indices of physical fields corresponding to the selected logical fields of a
TableSchema . |
static int[] |
TypeMappingUtils.computePhysicalIndicesOrTimeAttributeMarkers(TableSource<?> tableSource,
List<TableColumn> logicalColumns,
boolean streamMarkers,
java.util.function.Function<String,String> nameRemapping)
Computes indices of physical fields corresponding to the selected logical fields of a
TableSchema . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.