Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.planner.connectors |
Modifier and Type | Method and Description |
---|---|
static Column.MetadataColumn |
Column.metadata(String name,
DataType dataType,
String metadataKey,
boolean isVirtual)
Creates a metadata column from metadata of the given column name or from metadata of the
given key (if not null).
|
Column.MetadataColumn |
Column.MetadataColumn.withComment(String comment) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Column.MetadataColumn> |
DynamicSourceUtils.createMetadataKeysToMetadataColumnsMap(ResolvedSchema schema)
Returns a map record the mapping relation between metadataKeys to metadataColumns in input
schema.
|
static List<Column.MetadataColumn> |
DynamicSourceUtils.createRequiredMetadataColumns(ResolvedSchema schema,
DynamicTableSource source)
Returns a list of required metadata columns.
|
static List<Column.MetadataColumn> |
DynamicSourceUtils.extractMetadataColumns(ResolvedSchema schema) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.