Apache Flink：推断像 Spark 这样的 CSV 文件的模式
Apache Flink: Infer schema of a CSV file like Spark
在 Spark 中，我们可以使用推断模式从文件中动态读取模式，例如：
df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')
在 Flink 中有同样的方法吗？
Flink 没有内置支持从 CSV 文件自动推断模式。
您可以通过分析 CSV 文件的第一行并生成相应的 CsvTableSource 在顶部实现此类功能。
在 Spark 中，我们可以使用推断模式从文件中动态读取模式，例如：
df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')
在 Flink 中有同样的方法吗？
Flink 没有内置支持从 CSV 文件自动推断模式。
您可以通过分析 CSV 文件的第一行并生成相应的 CsvTableSource 在顶部实现此类功能。