DynamicTableSourcewhich only works with the Blink planner. See FLIP-95 for more information.
@Deprecated @PublicEvolving public interface DefinedFieldMapping
DefinedFieldMappinginterface provides a mapping for the fields of the table schema (
TableSource.getTableSchema()to fields of the physical produced data type
TableSource does not implement the
DefinedFieldMapping interface, the
fields of its
TableSchema are mapped to the fields of its produced
If the fields cannot or should not be implicitly mapped by name, an explicit mapping can be provided by implementing this interface.
If a mapping is provided, all fields must be explicitly mapped.
|Modifier and Type||Method and Description|
Returns the mapping for the fields of the
@Nullable Map<String,String> getFieldMapping()
TableSchemato the fields of its produced
The mapping is done based on field names, e.g., a mapping "name" -> "f1" maps the schema
field "name" to the field "f1" of the produced data type, for example in this case the second
field of a
The returned mapping must map all fields (except proctime and rowtime fields) to the
produced data type. It can also provide a mapping for fields which are not in the
TableSchema to make fields in the physical
DataType accessible for a
DataTypefields or null if no mapping is necessary.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.