Spark では、infer schema を使用して、ファイルからスキーマを動的に読み取ることができます。
df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')
Flinkで同じことをする方法はありますか?
Spark では、infer schema を使用して、ファイルからスキーマを動的に読み取ることができます。
df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')
Flinkで同じことをする方法はありますか?