在spark中，我们可以使用推断模式从文件中动态读取模式，例如：
df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')
在Flink也有同样的方法吗？
pxyaymoc1#
flink不支持从csv文件自动推断模式。您可以通过分析csv文件的第一行并生成相应的csvtablesource来实现这种功能。
1条答案
按热度按时间pxyaymoc1#
flink不支持从csv文件自动推断模式。
您可以通过分析csv文件的第一行并生成相应的csvtablesource来实现这种功能。