我需要获取 cvs 标头详细信息,例如标头名称、标头计数、标头数据类型。
此外,这个 csv 文件在不同的时间会有所不同。所以我想制作一个通用映射器,它可以读取任何文件,提取标题并映射到通用映射器。
示例:我有一个 csv 文件说 file1.csv,其中 3 列/标题说名称、地址、国家。在读取这个 csv 文件时,这三列将被映射到一个通用映射器或 pojo,比如 CommonCsvAttribute。
现在,一旦我有另一个 csv 文件说 file2.csv,它有 5 列说部门 ID、部门名称、部门位置、部门负责人、部门计数。在阅读此 csv 文件时,这 5 列/标题应映射到相同的 pojo CommonCsvAttribute。
将来,如果其他文件带有不同数量的列/标题,则应将其映射到相同的映射器 pojo CommonCsvAttribute。
为了实现这一点,我正在考虑动态读取标题/列,然后对其进行映射。
那么有什么方法可以在 flink 中读取这些标题/列详细信息吗?