小编Leo*_*ima的帖子

我正在尝试使用 Autoloader 加载多种类型的 csv 文件，它当前将我放入一个大镶木地板表中的所有 csv 合并，我想要的是为每种类型的 schema/csv_file 创建镶木地板表

当前代码的作用是：

#Streaming files/ waiting a file to be dropped
spark.readStream.format("cloudFiles") \
  .option("cloudFiles.format", "csv") \
  .option("delimiter", "~|~") \
  .option("cloudFiles.inferColumnTypes","true") \
  .option("cloudFiles.schemaLocation", pathCheckpoint) \
  .load(sourcePath) \
  .writeStream \
  .format("delta") \
  .option("mergeSchema", "true") \
  .option("checkpointLocation", pathCheckpoint) \
  .start(pathResult)

我想要的是