apache-flink - Apache Flink：推断 CSV 文件的架构，如 Spark

Question

在 Spark 中，我们可以使用推断模式从文件中动态读取模式，例如：

df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')

有没有办法在 Flink 中做同样的事情？

Answer 1

Flink 没有内置对 CSV 文件自动模式推断的支持。

您可以通过分析 CSV 文件的第一行并生成相应的 CsvTableSource 来实现此类功能。