Interface DefinedFieldMapping
-
- All Known Implementing Classes:
StreamSQLTestProgram.GeneratorTableSource
@Deprecated @Internal public interface DefinedFieldMapping
Deprecated.This interface will not be supported in the new source design aroundDynamicTableSource
. See FLIP-95 for more information.TheDefinedFieldMapping
interface provides a mapping for the fields of the table schema (TableSource.getTableSchema()
to fields of the physical produced data typeTableSource.getProducedDataType()
of aTableSource
.If a
TableSource
does not implement theDefinedFieldMapping
interface, the fields of itsTableSchema
are mapped to the fields of its producedDataType
by name.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.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description Map<String,String>
getFieldMapping()
Deprecated.Returns the mapping for the fields of theTableSource
'sTableSchema
to the fields of its producedDataType
.
-
-
-
Method Detail
-
getFieldMapping
@Nullable Map<String,String> getFieldMapping()
Deprecated.Returns the mapping for the fields of theTableSource
'sTableSchema
to the fields of its producedDataType
.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
Tuple
.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 physicalDataType
accessible for aTimestampExtractor
.- Returns:
- A mapping from
TableSchema
fields toDataType
fields or null if no mapping is necessary.
-
-