Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.utils |
Modifier and Type | Method and Description |
---|---|
static TableColumn |
TableColumn.of(String name,
DataType type)
Creates a table column from given name and data type.
|
static TableColumn |
TableColumn.of(String name,
DataType type,
String expression)
Creates a table column from given name and computation expression.
|
Modifier and Type | Method and Description |
---|---|
Optional<TableColumn> |
TableSchema.getTableColumn(int fieldIndex)
Returns the
TableColumn instance for the given field index. |
Optional<TableColumn> |
TableSchema.getTableColumn(String fieldName)
Returns the
TableColumn instance for the given field name. |
List<TableColumn> |
TableSchema.getTableColumns()
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 int[] |
PrintUtils.columnWidthsByType(List<TableColumn> columns,
int maxColumnWidth,
String nullColumn,
String rowKindColumn)
Try to derive column width based on column types.
|
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–2021 The Apache Software Foundation. All rights reserved.