org.apache.flink.table.api.TableSchema已弃用，是否考虑StarRocksDynamicSourceFunction中进行修改？

StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0

192 stars 154 forks source link

Open aesirteam opened 11 months ago

aesirteam commented 11 months ago

public class StarRocksSourceCommonFunc { ... public static Map<String, ColumnRichInfo> genColumnMap(TableSchema flinkSchema) ... }

可将TableSchema更换为org.apache.flink.table.api.Schema